Build full-stack apps in minutes

Fast, global apps and services with just an API and a few lines of code. Forget about infrastructure and focus on shipping products and features in a fraction of the time.

You write the code, we’ll make it fast. No DevOps required.


const jsc8 = require("jsc8");
const client = new jsc8({
  url: "https://gdn.paas.macrometa.io",
  apiKey: "XXXX"
});

(async () =>{
  const collection = await client.createCollection("employees", {
    stream: true
  });

  console.log("Collection created", collection);
})();

View on GitHub


from c8 import C8Client

fed_url = "gdn.paas.macrometa.io"
guest_mail = "[email protected]"
guest_password = "xxxxxx"

geo_fabric = "_system"
collection_name = "employees"

if __name__ == '__main__':
    print("\n ------- CONNECTION SETUP  ------")
    print("tenant: {}, geofabric:{}".format(guest_mail, geo_fabric))
    client = C8Client(protocol='https', host=fed_url, port=443,
                      email=guest_mail, password=guest_password,
                      geofabric=geo_fabric)

    print("\n ------- CREATE GEO-REPLICATED COLLECTION  ------")
    if client.has_collection(collection_name):
        print("Collection exists")
    else:
        employees = client.create_collection(collection_name)
        print("Created collection: {}".format(collection_name))

View on GitHub


gdnsl collection create employees --type doc --stream


const jsc8 = require("jsc8");
const client = new jsc8({
  url: "https://gdn.paas.macrometa.io",
  apiKey: "XXXX"
});

(async () => {
    const record = "INSERT { 'firstname': @firstname, 'lastname': @lastname, 'email': @email, 'zipcode': @zipcode, '_key': @email } IN employees";
    const queryWorker = await client.createRestql("insertRecord", record, {});

    console.log("Created query worker!", queryWorker);
})();

View on GitHub


from c8 import C8Client
fed_url = "gdn.paas.macrometa.io"
guest_mail = "[email protected]"
guest_password = "xxxxxx"

geo_fabric = "_system"
collection_name = "employees"

value = "INSERT {'firstname':@firstname, 'lastname':@lastname, 'email':@email, 'zipcode':@zipcode, '_key': 'abc'} IN %s" % collection_name
parameter = {"firstname": "", "lastname": "", "email": "", "zipcode": ""}

insert_data = {"query": {"name": "insertRecord",
                         "parameter": parameter, "value": value}}

if __name__ == '__main__':

    print("\n ------- CONNECTION SETUP  ------")
    print("tenant: {}, geofabric:{}".format(guest_mail, geo_fabric))
    client = C8Client(protocol='https', host=fed_url, port=443,
                      email=guest_mail, password=guest_password,
                      geofabric=geo_fabric)

    print("\n ------- CREATE QUERY WORKER  ------")
    client.create_restql(insert_data)  # name: insertRecord
    print("Created RESTQLs:{}".format(client.get_restqls()))

View on GitHub


gdnsl query-worker create insertData --value "INSERT {'firstname':@firstname, 'lastname':@lastname, 'email':@email, 'zipcode':@zipcode} IN employees"

View on GitHub


const jsc8 = require("jsc8");
const client = new jsc8({
  url: "https://gdn.paas.macrometa.io",
  apiKey: "XXXX"
});

(async () => {
    const record = {
      "firstname": "john", 
      "lastname": "doe",
      "email": "[email protected]", 
      "zipcode": "511037"
    };

    await client.executeRestql("insertRecord", record);

    console.log("Data inserted into query worker!");
})();

View on GitHub


from c8 import C8Client

fed_url = "gdn.paas.macrometa.io"
guest_mail = "[email protected]"
guest_password = "xxxxxx"
geo_fabric = "_system"
collection_name = "employees"

if __name__ == '__main__':

    print("\n ------- CONNECTION SETUP  ------")
    print("tenant: {}, geofabric:{}".format(guest_mail, geo_fabric))
    client = C8Client(protocol='https', host=fed_url, port=443,
                      email=guest_mail, password=guest_password,
                      geofabric=geo_fabric)

    print("\n ------- EXECUTE RESTQLs ------")
    print("Insert data....")
    response = client.execute_restql(
        "insertRecord",
        {"bindVars": {"firstname": "john", "lastname": "doe",
                      "email": "[email protected]", "zipcode": "511037"}})


gdnsl query-worker run insertData --param "firstname=john" "lastname=doe" "[email protected]" "zipcode=94002"

View on GitHub


const jsc8 = require("jsc8");
const client = new jsc8({
  url: "https://gdn.paas.macrometa.io",
  apiKey: "XXXX"
});

(async () => {
  const realtimeListener = async () => {
    const listener = await client.onCollectionChange("employees");

    listener.on('message', (ent) => {
      console.log("Event =>", msg);
    });

    listener.on('open', () => {
      console.log("Connection open...")
    });

    listener.on('close', () => {
      console.log("Connection closed!")
    });
  }

  await realtimeListener();
})();

View on GitHub


from c8 import C8Client
import json
import requests

fed_url = "gdn.paas.macrometa.io"
guest_mail = "[email protected]"
guest_password = "xxxxxx"
geo_fabric = "_system"
collection_name = "employees"

def get_auth_token(email, password):
    data = {
            "email": email,
            "password": password,
    }
    data = json.dumps(data)
    url = f"https://api-{fed_url}/_open/auth"
    response = requests.post(url, data=data)
    if response.status_code == 200:
        body = json.loads(response.text)
        token = body.get("jwt")
        if (not token):
            print("Failed to get Authentication Token for URL: {},Email: {}".format(url, email))
    else:
        print("Failed to Authenticate the C8DB user for URL: {} and Email: {}. Error: {}".format(url, email, response.text))
        
    return token

def enable_collection_stream(token, fabricName, collectionName):
    data = { 
            "hasStream": True
    }
    data = json.dumps(data)
    url = f"https://api-{fed_url}/_fabric/{fabricName}/_api/collection/{collectionName}/properties"
    jwtToken = f"bearer {token}"   
    headers={'Authorization': jwtToken, 'accept' : "application/json" }
    response = requests.put(url, data=data, headers=headers)
    if response.status_code == 200:
        print("Enabled stream for collection: {}".format(collection_name))
    else:
        print("Failed to enable the stream for collection: {}, Error: {}".format(collection_name, response.status_code))
        
def callback_fn(event):
    print(event)
    
if __name__ == '__main__':
    print("tenant: {}, geofabric:{}".format(guest_mail, geo_fabric))
    token = get_auth_token(guest_mail, guest_password)    

    enable_collection_stream(token, geo_fabric, collection_name)
    
    # Get the C8DBClient object
    client = C8Client(protocol='https', host=fed_url, port=443,
                  email=guest_mail, password=guest_password,
                  geofabric=geo_fabric)
    
    # Subscribe to the stream
    client.on_change("employees", callback=callback_fn)

View on GitHub