fix: realtime events payload

Author: TorstenDittmann

docs/examples/functions/create-deployment.md

@@ -12,7 +12,7 @@ client
 ;
 
 
-let promise = functions.createDeployment('[FUNCTION_ID]', '[ENTRYPOINT]', new File([fileBlob], 'file.png'), false);
+let promise = functions.createDeployment('[FUNCTION_ID]', '[ENTRYPOINT]', 'file.png', false);
 
 promise.then(function (response) {
     console.log(response);

docs/examples/storage/create-file.md

@@ -12,7 +12,7 @@ client
 ;
 
 
-let promise = storage.createFile('[BUCKET_ID]', '[FILE_ID]', new File([fileBlob], 'file.png'));
+let promise = storage.createFile('[BUCKET_ID]', '[FILE_ID]', 'file.png');
 
 promise.then(function (response) {
     console.log(response);

src/models.d.ts

@@ -277,7 +277,7 @@ export namespace Models {
         /**
          * Collection attributes.
          */
-        attributes: string[];
+        attributes: (AttributeBoolean | AttributeInteger | AttributeFloat | AttributeEmail | AttributeEnum | AttributeUrl | AttributeIp | AttributeString)[];
         /**
          * Collection indexes.
          */
@@ -294,7 +294,7 @@ export namespace Models {
         /**
          * List of attributes.
          */
-        attributes: string[];
+        attributes: (AttributeBoolean | AttributeInteger | AttributeFloat | AttributeEmail | AttributeEnum | AttributeUrl | AttributeIp | AttributeString)[];
     }
     /**
      * AttributeString

src/services/functions.ts

@@ -371,7 +371,8 @@ export class Functions extends Service {
                     headers['x-appwrite-id'] = id;
                 }
 
-                const totalBuffer = new Uint8Array(Client.CHUNK_SIZE);
+                let totalBuffer = new Uint8Array(Client.CHUNK_SIZE);
+                let lastBufferIndex = -1;
 
                 for (let blockIndex = 0; blockIndex < Client.CHUNK_SIZE / Client.DENO_READ_CHUNK_SIZE; blockIndex++) {
                     const buf = new Uint8Array(Client.DENO_READ_CHUNK_SIZE);
@@ -384,7 +385,20 @@ export class Functions extends Service {
 
                     for (let byteIndex = 0; byteIndex < Client.DENO_READ_CHUNK_SIZE; byteIndex++) {
                         totalBuffer[(blockIndex * Client.DENO_READ_CHUNK_SIZE) + byteIndex] = buf[byteIndex];
+
+                        if(buf[byteIndex] !== 0) {
+                            lastBufferIndex = (blockIndex * Client.DENO_READ_CHUNK_SIZE) + byteIndex;
+                        }
+                    }
+                }
+
+                // Shrink empty bytes
+                if(lastBufferIndex !== -1) {
+                    const newTotalBuffer = new Uint8Array(lastBufferIndex + 1);
+                    for(let index = 0; index <= lastBufferIndex; index++) {
+                        newTotalBuffer[index] = totalBuffer[index];
                     }
+                    totalBuffer = newTotalBuffer;
                 }
 
                 payload['code'] = new File([totalBuffer], basename(code));

src/services/storage.ts

@@ -386,7 +386,8 @@ export class Storage extends Service {
                     headers['x-appwrite-id'] = id;
                 }
 
-                const totalBuffer = new Uint8Array(Client.CHUNK_SIZE);
+                let totalBuffer = new Uint8Array(Client.CHUNK_SIZE);
+                let lastBufferIndex = -1;
 
                 for (let blockIndex = 0; blockIndex < Client.CHUNK_SIZE / Client.DENO_READ_CHUNK_SIZE; blockIndex++) {
                     const buf = new Uint8Array(Client.DENO_READ_CHUNK_SIZE);
@@ -399,7 +400,20 @@ export class Storage extends Service {
 
                     for (let byteIndex = 0; byteIndex < Client.DENO_READ_CHUNK_SIZE; byteIndex++) {
                         totalBuffer[(blockIndex * Client.DENO_READ_CHUNK_SIZE) + byteIndex] = buf[byteIndex];
+
+                        if(buf[byteIndex] !== 0) {
+                            lastBufferIndex = (blockIndex * Client.DENO_READ_CHUNK_SIZE) + byteIndex;
+                        }
+                    }
+                }
+
+                // Shrink empty bytes
+                if(lastBufferIndex !== -1) {
+                    const newTotalBuffer = new Uint8Array(lastBufferIndex + 1);
+                    for(let index = 0; index <= lastBufferIndex; index++) {
+                        newTotalBuffer[index] = totalBuffer[index];
                     }
+                    totalBuffer = newTotalBuffer;
                 }
 
                 payload['file'] = new File([totalBuffer], basename(file));