Habitat-lora-gateway/ftp.c

#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <ctype.h>
#include <stdio.h>   	// Standard input/output definitions
#include <string.h>  	// String function definitions
#include <unistd.h>  	// UNIX standard function definitions
#include <fcntl.h>   	// File control definitions
#include <errno.h>   	// Error number definitions
#include <termios.h> 	// POSIX terminal control definitions
#include <stdint.h>
#include <stdlib.h>
#include <dirent.h>
#include <math.h>
#include <pthread.h>

#include "ftp.h"
#include "global.h"

void ConvertFile(char *FileName)
{
	char TargetFile[100], CommandLine[200], *ptr;
	
	strcpy(TargetFile, FileName);
	ptr = strchr(TargetFile, '.');
	if (ptr && Config.SSDVJpegFolder[0])
	{
		*ptr = '\0';
		strcat(TargetFile, ".JPG");
		
		// Now convert the file
		// LogMessage("Converting %s to %s\n", FileName, TargetFile);

		sprintf(CommandLine, "ssdv -d /tmp/%s %s/%s 2> /dev/null > /dev/null", FileName, Config.SSDVJpegFolder, TargetFile);
		// LogMessage("COMMAND %s\n", CommandLine);
		system(CommandLine);	
				
		if (Config.ftpServer[0] && Config.ftpUser[0] && Config.ftpPassword[0])
		{
			// Upload to ftp server
			sprintf(CommandLine, "curl -T %s %s -Q \"TYPE I\" --user %s:%s 2> /dev/null > /dev/null", TargetFile, Config.ftpServer, Config.ftpUser, Config.ftpPassword);
			system(CommandLine);
		}
	}
}


void *FTPLoop(void *some_void_ptr)
{
    while (1)
    {
		DIR *dp;
		struct dirent *ep;
		struct stat st;
		char *SSDVFolder;
		char FileName[100], TempName[100];
	
		SSDVFolder = "/tmp";
				
		dp = opendir(SSDVFolder);
		if (dp != NULL)
		{
			while (ep = readdir (dp))
			{
				if (strstr(ep->d_name, ".bin") != NULL)
				{
					sprintf(FileName, "%s/%s", SSDVFolder, ep->d_name);
					stat(FileName, &st);
					// LogMessage("Age of '%s' is %ld seconds\n", FileName, time(0) - st.st_mtime);
					if ((time(0) - st.st_mtime) < 20)
					{
						ConvertFile(ep->d_name);
					}
					else if ((time(0) - st.st_mtime) > 120)
					{
						sprintf(TempName, "%s/%s", SSDVFolder, ep->d_name);
						LogMessage("Removing %s\n", TempName);
						remove(TempName);
					}
				}
			}
		}
		(void) closedir (dp);
		
		sleep(5);
	}
}