modified: controlplane/create_action.sh renamed: function_modules/noop/test1.json -> controlplane/dag_specifications/test1.json new file: controlplane/invoke.sh modified: controlplane/registrations/function_register.py renamed: function_modules/noop/run_trigger.sh -> controlplane/run_trigger.sh modified: controlplane/trigger_gateway.py modified: controlplane/trigger_specifications/trigger1.json deleted: function_modules/noop/cJSON.c deleted: function_modules/noop/cJSON.h deleted: function_modules/noop/image_from_sftp.c deleted: function_modules/noop/image_from_sftp.h deleted: function_modules/noop/invoke.sh deleted: function_modules/noop/noop deleted: function_modules/noop/update_action.shanubhav
parent
3143d80939
commit
f9329ef9d0
@ -0,0 +1,10 @@
|
||||
#!/bin/bash
|
||||
actionname=$1
|
||||
number=$2
|
||||
|
||||
cd /home/ubuntu/DAGit/function_modules/testaction
|
||||
python3 ../../controlplane/registrations/function_register.py test.py Dockerfile requirements.txt $actionname$number
|
||||
cd /home/ubuntu/DAGit/function_modules/$actionname
|
||||
sudo /home/ubuntu/DAGit/controlplane/buildAndPush.sh $actionname-image 10.0.0.27:5000
|
||||
wsk -i action update $actionname$number --docker 10.0.0.27:5000/$actionname-image
|
||||
#wsk -i action invoke noop --result
|
||||
@ -1,6 +1,6 @@
|
||||
{
|
||||
"trigger_name": "mydagtrigger",
|
||||
"trigger_name": "noop5_dag",
|
||||
"type":"dag",
|
||||
"dags": ["toonify"],
|
||||
"dags": ["noop5_dag"],
|
||||
"functions":""
|
||||
}
|
||||
File diff suppressed because it is too large
Load Diff
@ -1,306 +0,0 @@
|
||||
/*
|
||||
Copyright (c) 2009-2017 Dave Gamble and cJSON contributors
|
||||
|
||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
of this software and associated documentation files (the "Software"), to deal
|
||||
in the Software without restriction, including without limitation the rights
|
||||
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||
copies of the Software, and to permit persons to whom the Software is
|
||||
furnished to do so, subject to the following conditions:
|
||||
|
||||
The above copyright notice and this permission notice shall be included in
|
||||
all copies or substantial portions of the Software.
|
||||
|
||||
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
||||
THE SOFTWARE.
|
||||
*/
|
||||
|
||||
#ifndef cJSON__h
|
||||
#define cJSON__h
|
||||
|
||||
#ifdef __cplusplus
|
||||
extern "C"
|
||||
{
|
||||
#endif
|
||||
|
||||
#if !defined(__WINDOWS__) && (defined(WIN32) || defined(WIN64) || defined(_MSC_VER) || defined(_WIN32))
|
||||
#define __WINDOWS__
|
||||
#endif
|
||||
|
||||
#ifdef __WINDOWS__
|
||||
|
||||
/* When compiling for windows, we specify a specific calling convention to avoid issues where we are being called from a project with a different default calling convention. For windows you have 3 define options:
|
||||
|
||||
CJSON_HIDE_SYMBOLS - Define this in the case where you don't want to ever dllexport symbols
|
||||
CJSON_EXPORT_SYMBOLS - Define this on library build when you want to dllexport symbols (default)
|
||||
CJSON_IMPORT_SYMBOLS - Define this if you want to dllimport symbol
|
||||
|
||||
For *nix builds that support visibility attribute, you can define similar behavior by
|
||||
|
||||
setting default visibility to hidden by adding
|
||||
-fvisibility=hidden (for gcc)
|
||||
or
|
||||
-xldscope=hidden (for sun cc)
|
||||
to CFLAGS
|
||||
|
||||
then using the CJSON_API_VISIBILITY flag to "export" the same symbols the way CJSON_EXPORT_SYMBOLS does
|
||||
|
||||
*/
|
||||
|
||||
#define CJSON_CDECL __cdecl
|
||||
#define CJSON_STDCALL __stdcall
|
||||
|
||||
/* export symbols by default, this is necessary for copy pasting the C and header file */
|
||||
#if !defined(CJSON_HIDE_SYMBOLS) && !defined(CJSON_IMPORT_SYMBOLS) && !defined(CJSON_EXPORT_SYMBOLS)
|
||||
#define CJSON_EXPORT_SYMBOLS
|
||||
#endif
|
||||
|
||||
#if defined(CJSON_HIDE_SYMBOLS)
|
||||
#define CJSON_PUBLIC(type) type CJSON_STDCALL
|
||||
#elif defined(CJSON_EXPORT_SYMBOLS)
|
||||
#define CJSON_PUBLIC(type) __declspec(dllexport) type CJSON_STDCALL
|
||||
#elif defined(CJSON_IMPORT_SYMBOLS)
|
||||
#define CJSON_PUBLIC(type) __declspec(dllimport) type CJSON_STDCALL
|
||||
#endif
|
||||
#else /* !__WINDOWS__ */
|
||||
#define CJSON_CDECL
|
||||
#define CJSON_STDCALL
|
||||
|
||||
#if (defined(__GNUC__) || defined(__SUNPRO_CC) || defined (__SUNPRO_C)) && defined(CJSON_API_VISIBILITY)
|
||||
#define CJSON_PUBLIC(type) __attribute__((visibility("default"))) type
|
||||
#else
|
||||
#define CJSON_PUBLIC(type) type
|
||||
#endif
|
||||
#endif
|
||||
|
||||
/* project version */
|
||||
#define CJSON_VERSION_MAJOR 1
|
||||
#define CJSON_VERSION_MINOR 7
|
||||
#define CJSON_VERSION_PATCH 18
|
||||
|
||||
#include <stddef.h>
|
||||
|
||||
/* cJSON Types: */
|
||||
#define cJSON_Invalid (0)
|
||||
#define cJSON_False (1 << 0)
|
||||
#define cJSON_True (1 << 1)
|
||||
#define cJSON_NULL (1 << 2)
|
||||
#define cJSON_Number (1 << 3)
|
||||
#define cJSON_String (1 << 4)
|
||||
#define cJSON_Array (1 << 5)
|
||||
#define cJSON_Object (1 << 6)
|
||||
#define cJSON_Raw (1 << 7) /* raw json */
|
||||
|
||||
#define cJSON_IsReference 256
|
||||
#define cJSON_StringIsConst 512
|
||||
|
||||
/* The cJSON structure: */
|
||||
typedef struct cJSON
|
||||
{
|
||||
/* next/prev allow you to walk array/object chains. Alternatively, use GetArraySize/GetArrayItem/GetObjectItem */
|
||||
struct cJSON *next;
|
||||
struct cJSON *prev;
|
||||
/* An array or object item will have a child pointer pointing to a chain of the items in the array/object. */
|
||||
struct cJSON *child;
|
||||
|
||||
/* The type of the item, as above. */
|
||||
int type;
|
||||
|
||||
/* The item's string, if type==cJSON_String and type == cJSON_Raw */
|
||||
char *valuestring;
|
||||
/* writing to valueint is DEPRECATED, use cJSON_SetNumberValue instead */
|
||||
int valueint;
|
||||
/* The item's number, if type==cJSON_Number */
|
||||
double valuedouble;
|
||||
|
||||
/* The item's name string, if this item is the child of, or is in the list of subitems of an object. */
|
||||
char *string;
|
||||
} cJSON;
|
||||
|
||||
typedef struct cJSON_Hooks
|
||||
{
|
||||
/* malloc/free are CDECL on Windows regardless of the default calling convention of the compiler, so ensure the hooks allow passing those functions directly. */
|
||||
void *(CJSON_CDECL *malloc_fn)(size_t sz);
|
||||
void (CJSON_CDECL *free_fn)(void *ptr);
|
||||
} cJSON_Hooks;
|
||||
|
||||
typedef int cJSON_bool;
|
||||
|
||||
/* Limits how deeply nested arrays/objects can be before cJSON rejects to parse them.
|
||||
* This is to prevent stack overflows. */
|
||||
#ifndef CJSON_NESTING_LIMIT
|
||||
#define CJSON_NESTING_LIMIT 1000
|
||||
#endif
|
||||
|
||||
/* Limits the length of circular references can be before cJSON rejects to parse them.
|
||||
* This is to prevent stack overflows. */
|
||||
#ifndef CJSON_CIRCULAR_LIMIT
|
||||
#define CJSON_CIRCULAR_LIMIT 10000
|
||||
#endif
|
||||
|
||||
/* returns the version of cJSON as a string */
|
||||
CJSON_PUBLIC(const char*) cJSON_Version(void);
|
||||
|
||||
/* Supply malloc, realloc and free functions to cJSON */
|
||||
CJSON_PUBLIC(void) cJSON_InitHooks(cJSON_Hooks* hooks);
|
||||
|
||||
/* Memory Management: the caller is always responsible to free the results from all variants of cJSON_Parse (with cJSON_Delete) and cJSON_Print (with stdlib free, cJSON_Hooks.free_fn, or cJSON_free as appropriate). The exception is cJSON_PrintPreallocated, where the caller has full responsibility of the buffer. */
|
||||
/* Supply a block of JSON, and this returns a cJSON object you can interrogate. */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_Parse(const char *value);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_ParseWithLength(const char *value, size_t buffer_length);
|
||||
/* ParseWithOpts allows you to require (and check) that the JSON is null terminated, and to retrieve the pointer to the final byte parsed. */
|
||||
/* If you supply a ptr in return_parse_end and parsing fails, then return_parse_end will contain a pointer to the error so will match cJSON_GetErrorPtr(). */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_ParseWithOpts(const char *value, const char **return_parse_end, cJSON_bool require_null_terminated);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_ParseWithLengthOpts(const char *value, size_t buffer_length, const char **return_parse_end, cJSON_bool require_null_terminated);
|
||||
|
||||
/* Render a cJSON entity to text for transfer/storage. */
|
||||
CJSON_PUBLIC(char *) cJSON_Print(const cJSON *item);
|
||||
/* Render a cJSON entity to text for transfer/storage without any formatting. */
|
||||
CJSON_PUBLIC(char *) cJSON_PrintUnformatted(const cJSON *item);
|
||||
/* Render a cJSON entity to text using a buffered strategy. prebuffer is a guess at the final size. guessing well reduces reallocation. fmt=0 gives unformatted, =1 gives formatted */
|
||||
CJSON_PUBLIC(char *) cJSON_PrintBuffered(const cJSON *item, int prebuffer, cJSON_bool fmt);
|
||||
/* Render a cJSON entity to text using a buffer already allocated in memory with given length. Returns 1 on success and 0 on failure. */
|
||||
/* NOTE: cJSON is not always 100% accurate in estimating how much memory it will use, so to be safe allocate 5 bytes more than you actually need */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_PrintPreallocated(cJSON *item, char *buffer, const int length, const cJSON_bool format);
|
||||
/* Delete a cJSON entity and all subentities. */
|
||||
CJSON_PUBLIC(void) cJSON_Delete(cJSON *item);
|
||||
|
||||
/* Returns the number of items in an array (or object). */
|
||||
CJSON_PUBLIC(int) cJSON_GetArraySize(const cJSON *array);
|
||||
/* Retrieve item number "index" from array "array". Returns NULL if unsuccessful. */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_GetArrayItem(const cJSON *array, int index);
|
||||
/* Get item "string" from object. Case insensitive. */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_GetObjectItem(const cJSON * const object, const char * const string);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_GetObjectItemCaseSensitive(const cJSON * const object, const char * const string);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_HasObjectItem(const cJSON *object, const char *string);
|
||||
/* For analysing failed parses. This returns a pointer to the parse error. You'll probably need to look a few chars back to make sense of it. Defined when cJSON_Parse() returns 0. 0 when cJSON_Parse() succeeds. */
|
||||
CJSON_PUBLIC(const char *) cJSON_GetErrorPtr(void);
|
||||
|
||||
/* Check item type and return its value */
|
||||
CJSON_PUBLIC(char *) cJSON_GetStringValue(const cJSON * const item);
|
||||
CJSON_PUBLIC(double) cJSON_GetNumberValue(const cJSON * const item);
|
||||
|
||||
/* These functions check the type of an item */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsInvalid(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsFalse(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsTrue(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsBool(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsNull(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsNumber(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsString(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsArray(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsObject(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsRaw(const cJSON * const item);
|
||||
|
||||
/* These calls create a cJSON item of the appropriate type. */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateNull(void);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateTrue(void);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateFalse(void);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateBool(cJSON_bool boolean);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateNumber(double num);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateString(const char *string);
|
||||
/* raw json */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateRaw(const char *raw);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateArray(void);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateObject(void);
|
||||
|
||||
/* Create a string where valuestring references a string so
|
||||
* it will not be freed by cJSON_Delete */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateStringReference(const char *string);
|
||||
/* Create an object/array that only references it's elements so
|
||||
* they will not be freed by cJSON_Delete */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateObjectReference(const cJSON *child);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateArrayReference(const cJSON *child);
|
||||
|
||||
/* These utilities create an Array of count items.
|
||||
* The parameter count cannot be greater than the number of elements in the number array, otherwise array access will be out of bounds.*/
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateIntArray(const int *numbers, int count);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateFloatArray(const float *numbers, int count);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateDoubleArray(const double *numbers, int count);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateStringArray(const char *const *strings, int count);
|
||||
|
||||
/* Append item to the specified array/object. */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_AddItemToArray(cJSON *array, cJSON *item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_AddItemToObject(cJSON *object, const char *string, cJSON *item);
|
||||
/* Use this when string is definitely const (i.e. a literal, or as good as), and will definitely survive the cJSON object.
|
||||
* WARNING: When this function was used, make sure to always check that (item->type & cJSON_StringIsConst) is zero before
|
||||
* writing to `item->string` */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_AddItemToObjectCS(cJSON *object, const char *string, cJSON *item);
|
||||
/* Append reference to item to the specified array/object. Use this when you want to add an existing cJSON to a new cJSON, but don't want to corrupt your existing cJSON. */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_AddItemReferenceToArray(cJSON *array, cJSON *item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_AddItemReferenceToObject(cJSON *object, const char *string, cJSON *item);
|
||||
|
||||
/* Remove/Detach items from Arrays/Objects. */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_DetachItemViaPointer(cJSON *parent, cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_DetachItemFromArray(cJSON *array, int which);
|
||||
CJSON_PUBLIC(void) cJSON_DeleteItemFromArray(cJSON *array, int which);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_DetachItemFromObject(cJSON *object, const char *string);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_DetachItemFromObjectCaseSensitive(cJSON *object, const char *string);
|
||||
CJSON_PUBLIC(void) cJSON_DeleteItemFromObject(cJSON *object, const char *string);
|
||||
CJSON_PUBLIC(void) cJSON_DeleteItemFromObjectCaseSensitive(cJSON *object, const char *string);
|
||||
|
||||
/* Update array items. */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_InsertItemInArray(cJSON *array, int which, cJSON *newitem); /* Shifts pre-existing items to the right. */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_ReplaceItemViaPointer(cJSON * const parent, cJSON * const item, cJSON * replacement);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_ReplaceItemInArray(cJSON *array, int which, cJSON *newitem);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_ReplaceItemInObject(cJSON *object,const char *string,cJSON *newitem);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_ReplaceItemInObjectCaseSensitive(cJSON *object,const char *string,cJSON *newitem);
|
||||
|
||||
/* Duplicate a cJSON item */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_Duplicate(const cJSON *item, cJSON_bool recurse);
|
||||
/* Duplicate will create a new, identical cJSON item to the one you pass, in new memory that will
|
||||
* need to be released. With recurse!=0, it will duplicate any children connected to the item.
|
||||
* The item->next and ->prev pointers are always zero on return from Duplicate. */
|
||||
/* Recursively compare two cJSON items for equality. If either a or b is NULL or invalid, they will be considered unequal.
|
||||
* case_sensitive determines if object keys are treated case sensitive (1) or case insensitive (0) */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_Compare(const cJSON * const a, const cJSON * const b, const cJSON_bool case_sensitive);
|
||||
|
||||
/* Minify a strings, remove blank characters(such as ' ', '\t', '\r', '\n') from strings.
|
||||
* The input pointer json cannot point to a read-only address area, such as a string constant,
|
||||
* but should point to a readable and writable address area. */
|
||||
CJSON_PUBLIC(void) cJSON_Minify(char *json);
|
||||
|
||||
/* Helper functions for creating and adding items to an object at the same time.
|
||||
* They return the added item or NULL on failure. */
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddNullToObject(cJSON * const object, const char * const name);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddTrueToObject(cJSON * const object, const char * const name);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddFalseToObject(cJSON * const object, const char * const name);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddBoolToObject(cJSON * const object, const char * const name, const cJSON_bool boolean);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddNumberToObject(cJSON * const object, const char * const name, const double number);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddStringToObject(cJSON * const object, const char * const name, const char * const string);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddRawToObject(cJSON * const object, const char * const name, const char * const raw);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddObjectToObject(cJSON * const object, const char * const name);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddArrayToObject(cJSON * const object, const char * const name);
|
||||
|
||||
/* When assigning an integer value, it needs to be propagated to valuedouble too. */
|
||||
#define cJSON_SetIntValue(object, number) ((object) ? (object)->valueint = (object)->valuedouble = (number) : (number))
|
||||
/* helper for the cJSON_SetNumberValue macro */
|
||||
CJSON_PUBLIC(double) cJSON_SetNumberHelper(cJSON *object, double number);
|
||||
#define cJSON_SetNumberValue(object, number) ((object != NULL) ? cJSON_SetNumberHelper(object, (double)number) : (number))
|
||||
/* Change the valuestring of a cJSON_String object, only takes effect when type of object is cJSON_String */
|
||||
CJSON_PUBLIC(char*) cJSON_SetValuestring(cJSON *object, const char *valuestring);
|
||||
|
||||
/* If the object is not a boolean type this does nothing and returns cJSON_Invalid else it returns the new type*/
|
||||
#define cJSON_SetBoolValue(object, boolValue) ( \
|
||||
(object != NULL && ((object)->type & (cJSON_False|cJSON_True))) ? \
|
||||
(object)->type=((object)->type &(~(cJSON_False|cJSON_True)))|((boolValue)?cJSON_True:cJSON_False) : \
|
||||
cJSON_Invalid\
|
||||
)
|
||||
|
||||
/* Macro for iterating over an array or object */
|
||||
#define cJSON_ArrayForEach(element, array) for(element = (array != NULL) ? (array)->child : NULL; element != NULL; element = element->next)
|
||||
|
||||
/* malloc/free objects using the malloc/free functions that have been set with cJSON_InitHooks */
|
||||
CJSON_PUBLIC(void *) cJSON_malloc(size_t size);
|
||||
CJSON_PUBLIC(void) cJSON_free(void *object);
|
||||
|
||||
#ifdef __cplusplus
|
||||
}
|
||||
#endif
|
||||
|
||||
#endif
|
||||
@ -1,318 +0,0 @@
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
#include <libssh2.h>
|
||||
#include <libssh2_sftp.h>
|
||||
#include <string.h>
|
||||
#include <errno.h>
|
||||
#include <sys/socket.h>
|
||||
#include <netinet/in.h>
|
||||
#include <arpa/inet.h>
|
||||
#include <unistd.h>
|
||||
#include "image_from_sftp.h"
|
||||
|
||||
|
||||
|
||||
void print_error(const char *message) {
|
||||
fprintf(stderr, "%s: %d\n", message, libssh2_session_last_error(NULL, NULL, NULL, 0));
|
||||
}
|
||||
|
||||
int create_socket(const char *hostname, int port) {
|
||||
int sock;
|
||||
struct sockaddr_in sin;
|
||||
|
||||
sock = socket(AF_INET, SOCK_STREAM, 0);
|
||||
if (sock < 0) {
|
||||
print_error("Failed to create socket");
|
||||
return -1;
|
||||
}
|
||||
|
||||
sin.sin_family = AF_INET;
|
||||
sin.sin_port = htons(port);
|
||||
inet_pton(AF_INET, hostname, &sin.sin_addr);
|
||||
|
||||
if (connect(sock, (struct sockaddr *)(&sin), sizeof(struct sockaddr_in)) != 0) {
|
||||
close(sock);
|
||||
print_error("Failed to connect to server");
|
||||
return -1;
|
||||
}
|
||||
|
||||
return sock;
|
||||
}
|
||||
|
||||
char *filepathname (char*filepath,char*filename){
|
||||
size_t fullPathLength = strlen(filepath) + strlen(filename) + 1;
|
||||
// 动态分配内存
|
||||
char *fullPath = (char *)malloc(fullPathLength);
|
||||
if (fullPath == NULL) {
|
||||
perror("Failed to allocate memory");
|
||||
return NULL;
|
||||
}
|
||||
strcpy(fullPath, filepath);
|
||||
strcat(fullPath, filename);
|
||||
return fullPath;
|
||||
}
|
||||
|
||||
int upload_file(char *localfilename,char *remotefilename) {
|
||||
int rc;
|
||||
LIBSSH2_SESSION *session;
|
||||
LIBSSH2_SFTP *sftp;
|
||||
LIBSSH2_SFTP_HANDLE *sftp_handle;
|
||||
char *mem;
|
||||
size_t nread;
|
||||
size_t total = 0;
|
||||
struct stat fileinfo;
|
||||
FILE *local;
|
||||
const char *hostname = Hostname;
|
||||
const int port= Port;
|
||||
const char *username = Username;
|
||||
const char *password = Password;
|
||||
const char *localfile = NULL;
|
||||
const char *remotefile = NULL;
|
||||
char *localfilePath = LocalfilePath;
|
||||
char *remotefilePath = RemotefilePath;
|
||||
localfile = filepathname (localfilePath , localfilename);
|
||||
remotefile = filepathname (remotefilePath , remotefilename);
|
||||
// Initialize libssh2
|
||||
if (libssh2_init(0) != 0) {
|
||||
print_error("Failed to initialize libssh2");
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Create a session instance
|
||||
session = libssh2_session_init();
|
||||
if (session == NULL) {
|
||||
print_error("Failed to create SSH session");
|
||||
return -1;
|
||||
}
|
||||
|
||||
|
||||
// Start the session
|
||||
int sock = create_socket(hostname,port);
|
||||
if (libssh2_session_handshake(session, sock) != 0) {
|
||||
print_error("Failed to establish SSH session");
|
||||
libssh2_session_free(session);
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Authenticate
|
||||
if (libssh2_userauth_password(session, username, password) != 0) {
|
||||
print_error("Failed to authenticate");
|
||||
libssh2_session_free(session);
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Initialize SFTP session
|
||||
sftp = libssh2_sftp_init(session);
|
||||
if (!sftp) {
|
||||
print_error("Failed to initialize SFTP session");
|
||||
libssh2_session_free(session);
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Open the remote file for writing
|
||||
sftp_handle = libssh2_sftp_open(sftp, remotefile, LIBSSH2_FXF_WRITE | LIBSSH2_FXF_CREAT | LIBSSH2_FXF_TRUNC, 0644);
|
||||
if (!sftp_handle) {
|
||||
print_error("Failed to open remote file");
|
||||
libssh2_sftp_shutdown(sftp);
|
||||
libssh2_session_free(session);
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Open the local file for reading
|
||||
local = fopen(localfile, "rb");
|
||||
if (!local) {
|
||||
print_error("Failed to open local file");
|
||||
libssh2_sftp_close(sftp_handle);
|
||||
libssh2_sftp_shutdown(sftp);
|
||||
libssh2_session_free(session);
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Get the file size
|
||||
if (fstat(fileno(local), &fileinfo) != 0) {
|
||||
print_error("Failed to get file size");
|
||||
fclose(local);
|
||||
libssh2_sftp_close(sftp_handle);
|
||||
libssh2_sftp_shutdown(sftp);
|
||||
libssh2_session_free(session);
|
||||
return -1;
|
||||
}
|
||||
size_t filesize = fileinfo.st_size;
|
||||
|
||||
// Read from local and write to remote
|
||||
while (total < filesize) {
|
||||
char buffer[1024];
|
||||
nread = fread(buffer, 1, sizeof(buffer), local);
|
||||
if (nread < 0) {
|
||||
print_error("Error reading from local file");
|
||||
break;
|
||||
}
|
||||
if (nread > 0) {
|
||||
libssh2_sftp_write(sftp_handle, buffer, nread);
|
||||
total += nread;
|
||||
}
|
||||
}
|
||||
|
||||
// Cleanup
|
||||
fclose(local);
|
||||
libssh2_sftp_close(sftp_handle);
|
||||
libssh2_sftp_shutdown(sftp);
|
||||
libssh2_session_disconnect(session, "Normal Shutdown");
|
||||
libssh2_session_free(session);
|
||||
libssh2_exit();
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
int download_file(char *argv , char *file_format) {
|
||||
char *str = argv;
|
||||
char *value = NULL ;
|
||||
char *key = "\"action_name\": \"/guest/";
|
||||
char *perior_action[Perior_action_count];
|
||||
int perior_action_count=0;
|
||||
char *start = strstr(str, key);
|
||||
int length_file_format = strlen (file_format);
|
||||
while (start)
|
||||
{
|
||||
start =start+ strlen(key) /*+ 4*/; // 跳过键部分，指向值的开始
|
||||
char *end = strstr(start, "\"");
|
||||
//end +=2 ; // 查找值的结束引号
|
||||
int length = end - start ;
|
||||
value = (char *)malloc(length + 1 + length_file_format); // +1 用于存储字符串结束符
|
||||
if (value == NULL) printf("Memory allocation failed\n");
|
||||
if (end) {
|
||||
// 复制值到 value 中
|
||||
strncpy(value, start, length);
|
||||
value[length] = '\0'; // 添加字符串结束符
|
||||
strcat(value , file_format);
|
||||
}
|
||||
perior_action[perior_action_count]=value;
|
||||
perior_action_count++;
|
||||
start = strstr(end, key);
|
||||
|
||||
}
|
||||
//printf ("argv1:%s\n",argv[1]);
|
||||
char *localfilepath[perior_action_count];
|
||||
if (perior_action_count != 0){
|
||||
for (int i = 0; i < perior_action_count; i++){
|
||||
printf("perior action:%s\n",perior_action[i]);
|
||||
localfilepath[i] = filepathname(LocalfilePath,perior_action[i]);
|
||||
perior_action[i] = filepathname(RemotefilePath , perior_action[i]);
|
||||
}
|
||||
}
|
||||
//const char *actvation_id = getenv("__OW_ACTIVATION_ID");
|
||||
//const char *action = getenv("__OW_ACTION_NAME");
|
||||
//printf("{\"action_name\" : \"%s\", \"activation_id\":\"%s\",\"message\": \" hello world!\" }\n",action,actvation_id);
|
||||
int sock;
|
||||
LIBSSH2_SESSION *session;
|
||||
LIBSSH2_SFTP *sftp;
|
||||
LIBSSH2_SFTP_HANDLE *sftp_handle;
|
||||
ssize_t nread;
|
||||
char *hostname = Hostname;
|
||||
int port= Port;
|
||||
char *username = Username;
|
||||
char *password = Password;
|
||||
char *localfilePath = LocalfilePath ;
|
||||
char *localfile = NULL;
|
||||
char *remotefilePath = RemotefilePath ;
|
||||
char *remotefile = NULL;
|
||||
//remotefile = filepathname(remotefilePath,filename);
|
||||
//localfile = filepathname (localfilePath,filename);
|
||||
|
||||
// Initialize libssh2
|
||||
if (libssh2_init(0) != 0) {
|
||||
print_error("Failed to initialize libssh2");
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Create a socket and connect
|
||||
sock = create_socket(hostname, port);
|
||||
if (sock < 0) {
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Create a session instance
|
||||
session = libssh2_session_init();
|
||||
if (session == NULL) {
|
||||
close(sock);
|
||||
print_error("Failed to create SSH session");
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Start the session
|
||||
if (libssh2_session_handshake(session, sock) != 0) {
|
||||
print_error("Failed to establish SSH session");
|
||||
libssh2_session_free(session);
|
||||
close(sock);
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Authenticate
|
||||
if (libssh2_userauth_password(session, username, password) != 0) {
|
||||
print_error("Failed to authenticate");
|
||||
libssh2_session_free(session);
|
||||
close(sock);
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Initialize SFTP session
|
||||
sftp = libssh2_sftp_init(session);
|
||||
if (!sftp) {
|
||||
print_error("Failed to initialize SFTP session");
|
||||
libssh2_session_free(session);
|
||||
close(sock);
|
||||
return -1;
|
||||
}
|
||||
|
||||
for (int i = 0; i < perior_action_count; i++) {
|
||||
// Open the remote file for reading
|
||||
char buffer[1024];
|
||||
sftp_handle = libssh2_sftp_open(sftp, perior_action[i], LIBSSH2_FXF_READ, 0);
|
||||
if (!sftp_handle) {
|
||||
print_error("Failed to open remote file");
|
||||
libssh2_sftp_shutdown(sftp);
|
||||
libssh2_session_free(session);
|
||||
close(sock);
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Open the local file for writing
|
||||
FILE *local = fopen(localfilepath[i], "wb");
|
||||
if (!local) {
|
||||
print_error("Failed to open local file");
|
||||
libssh2_sftp_close(sftp_handle);
|
||||
libssh2_sftp_shutdown(sftp);
|
||||
libssh2_session_free(session);
|
||||
close(sock);
|
||||
return -1;
|
||||
}
|
||||
|
||||
// Read from remote and write to local
|
||||
while ((nread = libssh2_sftp_read(sftp_handle, buffer, sizeof(buffer))) > 0) {
|
||||
fwrite(buffer, 1, nread, local);
|
||||
}
|
||||
|
||||
if (nread < 0) {
|
||||
print_error("Error reading from remote file");
|
||||
}
|
||||
fclose(local);
|
||||
libssh2_sftp_close(sftp_handle);
|
||||
}
|
||||
|
||||
// Cleanup
|
||||
libssh2_sftp_shutdown(sftp);
|
||||
libssh2_session_disconnect(session, "Normal Shutdown");
|
||||
libssh2_session_free(session);
|
||||
close(sock);
|
||||
libssh2_exit();
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
int main (){
|
||||
upload_file("test.jpg","noop2.jpg");
|
||||
upload_file("test.jpg","noop3.jpg");
|
||||
download_file(" {\"__ow_body\": [{\"action_name\": \"/guest/noop2\", \"activation_id\": \"05a456e67d1247d7a456e67d12e7d7e4\", \"message\": \" hello world!\"}, {\"action_name\": \"/guest/noop3\", \"activation_id\": \"760ab5cf657d4a078ab5cf657d6a0798\", \"message\": \" hello world!\"}], \"__ow_headers\": {\"accept\": \"*/*\", \"accept-encoding\": \"gzip, deflate\", \"content-type\": \"application/json\", \"host\": \"controllers\", \"user-agent\": \"python-requests/2.18.4\", \"x-forwarded-for\": \"172.17.0.1\", \"x-forwarded-host\": \"172.17.0.1\", \"x-forwarded-port\": \"8080\", \"x-forwarded-proto\": \"http\", \"x-forwarded-url\": \"http://172.17.0.1/api/23bc46b1-71f6-4ed5-8c54-816aa4f8c502/noop4-api/noop4-path\", \"x-real-ip\": \"172.17.0.1\", \"x-request-id\": \"7b11d572a3f0ed4ff57394717b3ac473\"}, \"__ow_method\": \"post\", \"__ow_path\": \"\"} ",".jpg");
|
||||
return 0;
|
||||
}
|
||||
|
||||
@ -1,27 +0,0 @@
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
#include <libssh2.h>
|
||||
#include <libssh2_sftp.h>
|
||||
#include <string.h>
|
||||
#include <errno.h>
|
||||
#include <sys/socket.h>
|
||||
#include <netinet/in.h>
|
||||
#include <arpa/inet.h>
|
||||
#include <unistd.h>
|
||||
|
||||
#define Hostname "127.0.0.1"
|
||||
#define Port 22
|
||||
#define Username "sftpuser"
|
||||
#define Password "12580"
|
||||
#define LocalfilePath "./"
|
||||
#define RemotefilePath "/uploads/"
|
||||
#define Perior_action_count 5
|
||||
|
||||
#ifndef IMAGE_FROM_SFTP_H
|
||||
#define IMAGE_FROM_SFTP_H
|
||||
void print_error(const char *message);
|
||||
int create_socket(const char *hostname, int port);
|
||||
char *filepathname (char*filepath,char*filename);
|
||||
int upload_file(char *localfilename,char *remotefilename);
|
||||
int download_file(char *argv , char *file_format);
|
||||
#endif
|
||||
@ -1,5 +0,0 @@
|
||||
#!/bin/bash
|
||||
|
||||
sudo ./buildAndPush.sh noop-image localhost:5000
|
||||
wsk -i action update noop --docker localhost:5000/noop-image
|
||||
wsk -i action invoke noop --result
|
||||
Binary file not shown.
@ -1,7 +0,0 @@
|
||||
#!/bin/bash
|
||||
|
||||
wsk -i action update noop5 --docker localhost:5000/noop-image
|
||||
wsk -i action update noop4 --docker localhost:5000/noop-image
|
||||
wsk -i action update noop3 --docker localhost:5000/noop-image
|
||||
wsk -i action update noop2 --docker localhost:5000/noop-image
|
||||
wsk -i action update noop1 --docker localhost:5000/noop-image
|
||||
Loading…
Reference in new issue