Skip to content

Instantly share code, notes, and snippets.

@demosifter
demosifter / how-to-dag-1.1.json
Created June 1, 2018 16:23
"inputs" section of the "dag" in the sift.json
"emails":{
"gmailEmails":{
"filter":{
"conditions":[{
"date": "between now and 1 week before now"
}]
},
"wants": [
"archive",
"headers",
func Compute(req sandboxrpc.ComputeRequest) ([]sandboxrpc.ComputeResponse, error) {
inData := req.In.Data
if len(inData) != 1 {
return nil, fmt.Errorf("empty input")
}
var resp []sandboxrpc.ComputeResponse
v := inData[0]
idx, err := utils.OpenIndex(true)
if err != nil {
func Compute(req sandboxrpc.ComputeRequest) ([]sandboxrpc.ComputeResponse, error) {
idx, err := utils.OpenIndex(false)
if err != nil {
return nil, errors.New("Something went wrong while creating the index: " + err.Error())
}
defer idx.Close()
datums, err := fetchMajesticCSV()
if err != nil {
return nil, err
"dag": {
"inputs":{
"rpc":{
"search":{
"methods": ["GET"],
"path": "/_search",
"CORS":{}
}
}
},
"dag": {
"inputs":{
"rpc":{
"simple_rpc":{
"methods": ["GET"],
"path": "/edig/txt/*",
"CORS":{}
}
}
},
const dns = require('dns');
const pify = require('pify');
//...
module.exports = function (got) {
const inData = got.in.data;
console.log('edig: simple.js: data received:', inData);
return inData.map(d => {
const newResponse = (status_code, header, body) => {
return { status_code, header,
body: Buffer.from(JSON.stringify(body) || '').toString('base64')
}
}
module.exports = function (got) {
const inData = got.in.data;
console.log('edig: simple.js: data received:', inData);
{
"dag": {
"inputs": {
"rpc": {
"simple_rpc": {
"methods": ["GET"],
"path": "/simple",
"CORS": {}
}
}
loadThreadListView (listInfo) {
console.log('counter: loadThreadListView: ', listInfo);
if (listInfo) {
return {
template: '001_list_common_txt',
value: {
color: '#ffffff',
backgroundColor: '#e11010',
subtitle: listInfo + ' words'
}
<div class="column">
<p>I'm a Sift!</p>
<p id='number'>0</p>
</div>