Fail to run function python code #5952

blob84 · 2023-08-07T19:38:07Z

blob84
Aug 7, 2023

Hello this is the code, I can't figure out what is the problem. There is no log message, only "Internal error", where is the problem? The env variables exists.
main.py
`

import random
from appwrite.client import Client
from appwrite.services.databases import Databases
#from appwrite.services.functions import Functions
from appwrite import query
import json
import datetime
import traceback
from enum import Enum
from ssh_conn import execute

class ErrorCode(Enum):
    MEMBER_NOT_FOUND = 1
    EXPIRED = 2
    ERROR_OPEN_DORR = 3
    GENERIC = 4
    ERROR_CLOSE_DOOR = 5

def main(req, res):
    try:
        payload = json.loads(req.payload)

        ENDPOINT = req.variables.get('ENDPOINT')
        PROJECT_ID = req.variables.get('PROJECT_ID')
        PROJECT_KEY = req.variables.get('PROJECT_KEY')
        DATABASE_ID = req.variables.get("DATABASE_ID")
        COLLECTION_ID = req.variables.get("COLLECTION_ID")
        SSH_HOST = req.variables.get("SSH_HOST")
        SSH_NAME = req.variables.get("SSH_NAME")
        SSH_PASSWORD = req.variables.get("SSH_PASSWORD")
        SSH_SCRIPT_PATH = req.variables.get("SSH_SCRIPT_PATH")

        randomNumber = random.random()

        print(payload)

        if payload["ssh_command_param"] == "close":
            output = execute(
                SSH_HOST,
                SSH_NAME,
                SSH_PASSWORD,
                SSH_SCRIPT_PATH,
                payload["ssh_command_param"]
            )
            if output["stderr"]:
                return res.json({
                    'message': f'Fail {output["stderr"]}',
                    'success': False,
                    'error_code': ErrorCode.ERROR_CLOSE_DOOR,
                    'payload': payload,
                    #'secretKey': secretKey,
                    'randomNumber': randomNumber
                    #'trigger': trigger,
   
8000
             })

            return res.json({
                'message': 'Succes closing door',
                'success': True,
                'error_code': 0,
                'payload': payload,
                #'secretKey': secretKey,
                'randomNumber': randomNumber
                #'trigger': trigger,
            })


        client = Client()

        (client
        .set_endpoint(ENDPOINT)
        .set_project(PROJECT_ID) 
        .set_key(PROJECT_KEY) 
        .set_self_signed()
        )

        databases = Databases(client)

        result = databases.list_documents(
            DATABASE_ID, 
            COLLECTION_ID,
            [ query.Query.equal('email', payload["email"]) ]
        )

        print(result)

        if not result:
            return res.json({
                'message': 'Member not found',
                'success': False,
                'payload': payload,
                #'secretKey': secretKey,
                'randomNumber': randomNumber
                #'trigger': trigger,
            })

        doc_found = False
        documents = result['documents']
        for document in documents:
            if document["email"] == payload["email"]: 
                doc_found = True
                break

        if not doc_found:
            return res.json({
                'message': 'Member not found',
                'success': False,
                'error_code': ErrorCode.MEMBER_NOT_FOUND,
                'payload': payload,
                #'secretKey': secretKey,
                'randomNumber': randomNumber
                #'trigger': trigger,
            })        

        today = datetime.datetime.strptime(datetime.datetime.now().strftime("%d/%m/%Y-%H:%M:%S"), "%d/%m/%Y-%H:%M:%S")
        end_date = datetime.datetime.strptime(document["end_date"], "%d/%m/%Y-%H:%M:%S")
        sub = end_date - today
        if sub.days < 0:
            return res.json({
                'message': 'Fail expired date',
                'success': False,
                'error_code': ErrorCode.EXPIRED,
                'payload': payload,
                #'secretKey': secretKey,
                'randomNumber': randomNumber
                #'trigger': trigger,
            })
        else:
            # open door
            output = execute(
                SSH_HOST,
                SSH_NAME,
                SSH_PASSWORD,
                SSH_SCRIPT_PATH,
                "open"
            )
            if output["stderr"]:
                return res.json({
                    'message': f'Fail {output["stderr"]}',
                    'success': False,
                    'error_code': ErrorCode.ERROR_OPEN_DORR,
                    'payload': payload,
                    #'secretKey': secretKey,
                    'randomNumber': randomNumber
                    #'trigger': trigger,
                })

            return res.json({
                'message': 'Succes open',
                'success': True,
                'error_code': 0,
                'payload': payload,
                #'secretKey': secretKey,
                'randomNumber': randomNumber
                #'trigger': trigger,
            })
        
    except Exception as e:
        traceback.print_exc()
        return res.json({
            'message': f'Fail {e}',
            'success': False,
            'error_code': ErrorCode.GENERIC,
            'payload': payload,
            #'secretKey': secretKey,
            'randomNumber': randomNumber
            #'trigger': trigger,
        })`

```ssh_con.py

`from fabric import Connection

def execute(host, user, password, script_path, command_params):
remote_script_path = script_path

conn = None
try:
    conn = Connection(host=host, user=user, connect_kwargs={"password": password, 'timeout': 10})
except TimeoutError as e:
    raise e

result = conn.run('python {} {}'.format(remote_script_path, command_params), hide=True)

print("Output dello script:", result.stdout)

conn.close()

return {"stdout": result.stdoud, "stderr": result.stderr}`

requirements.txt

appwrite==2.0.2
bcrypt==4.0.1
certifi==2023.7.22
cffi==1.15.1
charset-normalizer==3.2.0
cryptography==41.0.3
decorator==5.1.1
fabric==3.1.0
idna==3.4
invoke==2.2.0
paramiko==3.3.1
pycparser==2.21
PyNaCl==1.5.0
requests==2.31.0
urllib3==2.0.4

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Fail to run function python code #5952

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{editor}}'s edit

{{editor}}'s edit

Uh oh!

Replies: 0 comments

Select a reply

Uh oh!

Fail to run function python code #5952

Uh oh!

Uh oh!

blob84 Aug 7, 2023

Replies: 0 comments

blob84
Aug 7, 2023