58 ipfs support system (#60)

* ADD IPFS TO UTIL AND PUT/GET

* add msg 2 websocket demo to test cid using awesome

* add cat to ipfs util

* working websocket to ipfs

Author: realcodywburns

examples/websocket_demo.js

@@ -1,9 +1,10 @@
 import { WebSocket } from "ws";
 
-const socket = new WebSocket("ws://localhost:8082");
+var socket = new WebSocket("ws://localhost:8082");
 const entities = [];
 const components = [];
 
+
 socket.onmessage = (event) => {
   const message = JSON.parse(event.data);
   console.log(message);
@@ -36,6 +37,21 @@ setInterval(()=> {
   socket.send(JSON.stringify({ type: "getAllComponents" }));
 }, 5000);
 
+
+setInterval(()=> {
+  socket.send(JSON.stringify({ type: "saveData" , componentName: 'IPFScid', data: "this is a test!" }));
+}, 3000);
+
+//lazy reload of websocket if I crash the server
+setInterval(()=> {
+  //console.log(socket.State);
+  try {
+    //if (socket.State == WebSocketState.Close) {socket = new WebSocket("ws://localhost:8082")}  
+    //console.log(socket.State);
+  } catch (error) {
+    console.log(error)
+  }  
+}, 5000)
 /*
 setTimeout(()=> {
   socket.send(JSON.stringify({ type: "createObjective", data: "Write the worlds greatest robot detective novel!"  }));

package.json

@@ -22,6 +22,8 @@
   "dependencies": {
     "crypto-js": "^4.1.1",
     "dotenv": "^16.0.3",
+    "ipfs": "^0.66.0",
+    "ipfs-core": "^0.18.0",
     "natural": "^6.2.0",
     "node-fetch": "^3.3.1",
     "openai": "^3.2.1",

src/components/active/IPFScid.mjs

@@ -0,0 +1,19 @@
+import { CHIPPRAGI } from "../../index.js";
+import { SchemaFieldTypes } from "redis";
+
+CHIPPRAGI.registerComponent('IPFScid', {
+  schema:{
+    '$.fileCID': {
+      type: SchemaFieldTypes.TEXT,
+      AS: 'cid'
+    }, 
+  },
+  
+  info: {
+    version : "0.1.0",
+    license : "APACHE-2.0",
+    developer: "CHIPPRBOTS",
+    multi: true,
+    description : "This component stores a files cid on the ipfs network",
+  },
+});

src/core/Util/Util.js

@@ -1,7 +1,15 @@
 import CryptoJS from 'crypto-js';
+import * as ipfs from 'ipfs';
 
 export class Utility {
   constructor(chipprConfig) {
+    this.node;  
+    this.init();
+  }
+
+  async init() {
+    this.node = await ipfs.create();
+    //console.log(this.node)
   }
 
   getHashId( _dataToHash ){
@@ -40,6 +48,25 @@ export class Utility {
       },
     });
   };
+
+  async storeData( data ){
+    // takes a data object in and returns a cid string
+    const results = await this.node.add(data)
+    //do something with results maybe
+    return results;
+  }
+
+  async getData( cid ){
+    for await (const buf of this.node.get(cid)) {
+      return buf;
+    }
+  }
+
+  async readData( cid ){
+    for await (const ary of this.node.cat(cid)) {
+      return ary;
+    }
+  }
 }
 
 

src/systems/active/AmazingSystem.mjs

@@ -5,20 +5,26 @@ CHIPPRAGI.registerSystem('AmazingSystem', {
     version : "0.1.0",
     license : "APACHE-2.0",
     developer: "CHIPPRBOTS",
+    type: "core",
     description : "This is an system that can solve any problem.",
   },
 
   init: function () {
-    //NOTE THIS IS FOR TESTING THE SYSTEM SELECTOR ONLY 
-    CHIPPRAGI.subscribe('SYSTEM', (type, eventData) => {
-      //if( type == 'systemSelected' ) //CHIPPRAGI.Logger.debug({log:`AMAZING SYSTEM WAS CORRECTLY SELECTED!`, system: 'amazingSystem'});
-    });
+    //NOTE THIS IS FOR TESTING THE SYSTEM ONLY 
+    CHIPPRAGI.subscribe('UPDATE', (eventData) => {this.update(eventData)});
   },
 
-  update: function (eventData) {
+  update: async function (message) {
     // Do something when the component's data is updated, if needed.
     // entityId is the ID of the entity this component is attached to.
     // componentData contains the updated data for the component.
+    let eventData = JSON.parse(message);
+    if (eventData.eventType === 'saveData') {
+      let cid = await CHIPPRAGI.Util.storeData(eventData.payload.data);
+      CHIPPRAGI.Logger.error({ systemName: 'awesome system', log: cid});
+      let file = await CHIPPRAGI.Util.readData(cid.path);
+      CHIPPRAGI.Logger.error({ systemName: 'awesome system', log: file.toString('utf8')});
+    }
   },
 
   remove: function (eventData) {

src/systems/active/WebsocketServerSystem.mjs

@@ -65,7 +65,11 @@ CHIPPRAGI.registerSystem("WebsocketServerSystem", {
     break;
     default:
       //dump on the message bus
-      CHIPPRAGI.MessageBus.publish('UPDATE', message);
+      let entityID = parsedMessage.entityID || null;
+      let componentName = parsedMessage.componentName || 'websocket';
+      let sourceSystem = parsedMessage.sourceSystem || 'WebsocketServerSystem';
+      let data = parsedMessage.data || {};
+      CHIPPRAGI.MessageBus.updateMessage( parsedMessage.type, entityID, componentName, sourceSystem, data );
     }
   },