SDK du Modélisateur de Processus

var SF = {
  collection : Object,
  user : Object,
  file : Object,
  utils : Object,
  sql : Object,
  instance : Object,
  task : Object,
  process : Object,
  softyTable : Object, // SoftyTable instance with methods to interact with tables
  mode : String, // The current Mode this is setted automatically
};

let id = await SF.utils.nextValue("leave_request");
// retourne le nombre 1
let id = await SF.utils.nextValue("leave_request",5);
// retourne la chaîne 00001

let result = await SF.utils.shellExecLocal('echo Hello World');
// retourne: { data: 'Hello World' }

let result = await SF.utils.shellExecLocal('pwd');
// retourne: { data: '/home/user/project' }

let result = await SF.utils.shellExecRemote('ls -l', {
  host: '192.168.1.10',
  port: 22,
  username: 'user',
  password: 'password'
});
// retourne: { data: 'list of files and folders...', code: 0 }

let id = SF.utils.axios.get('/data/json/123')
  .then(function (response) {
    // traiter le succès
    console.log(response);
  }).catch(function (error) {
    // traiter l'erreur
    console.log(error);
  });

await SF.collection.insertMany("cost-centers",[{label : "IT", value : "it"}])

await SF.collection.insertOne("cost-centers",{label : "IT", value : "it"})

await SF.collection.findOne("cost-centers",{value : "it"})

await SF.collection.find("cost-centers",{value : "it"})

await SF.collection.updateOne("cost-centers",{value : "it"})

await SF.collection.update("cost-centers",{value : "it"})

await SF.collection.count("cost-centers")

await SF.collection.deleteOne("cost-centers")

await SF.collection.delete("cost-centers")

let aggregation = [
  {
    "$match": { "type": "type1" }
  },
  {
    "$project" : {
                    "_id": 1,
                    "name": 1
                  }
  }
]
await SF.collection.aggregate("cost-centers",[aggregation]);

await SF.collection.cleanCollection("cost-centers")

let bulkOps = [
  { insertOne: { document: { name: 'John', age: 30 } } },
  { updateOne: { filter: { name: 'John' }, update: { $set: { age: 31 } } } },
  { deleteOne: { filter: { name: 'John' } } }
];

await SF.utils.bulkWrite('users', bulkOps);
// retourne: Promesse résolue lorsque toutes les opérations sont terminées

await SF.user.getUsersinGroup("6042551d231e8c8ade19bc09")

await SF.user.getUsersInGroupList(["6042551d231e8c8ade19bc09","6040e3679c81cf1b60b698f4"])

let group = await SF.utils.getGroupById("60c72b2f9f1b2c3c8f3b8b0b");
// retourne: { _id: ObjectId("60c72b2f9f1b2c3c8f3b8b0b"), name: 'Admin', members: [...] }

let group = await SF.utils.getGroupById("60c72b2f9f1b2c3c8f3b8b0c");
// retourne: null (si le groupe avec cet ID n'existe pas)

await SF.user.getUserById("6042551d231e8c8ade19bc09")

await SF.user.getUserByMail("test@softydev.com")

await SF.user.updateUserById("6042551d231e8c8ade19bc09",{firstName : "test"})

await SF.user.updateUsersEach([{ _id: "6042551d231e8c8ade19bc09", payload: { firstName: 'firstUser' } }, { _id: "6042551d231e8c8ade19bc10", payload: { firstName: 'secondUser' } }])

await SF.user.updateUserMetadataById("6042551d231e8c8ade19bc09", "Manager",  "test")

await SF.user.getUsers()

await SF.user.getUserMetadata("6042551d231e8c8ade19bc09")

await SF.user.addUserToGroup("6042551d231e8c8ade19bc09", "62c2b6f74d16c2a2c19dcdb7")

await SF.user.removeUserfromGroup("6042551d231e8c8ade19bc09", "62c2b6f74d16c2a2c19dcdb7")

 var newUser = {
    firstName: "Jean",
    lastName: "Martin",
    email: "jean.martin@softy.io",
    group_test: [],
    group_uat: [],
    group: [],
    metadata_test: {},
    metadata_uat: {},
    metadata_prod: {},
    ideAccess: false,
    blocked: false,
    sendMail: false,
    getPassword: false
};

var user = await SF.user.createUser(newUser);

const file = new File(gridfsBucket);

let result = await file.getFileContentById("64bfa28cfabc123...", "utf8");
console.log(result.content);

let buffer = await file.getFileBufferById("64bfa28cfabc123...");

await file.generatePDFFromTemplate(null, 'templateId', {
  variables: { name: "John" },
  SF_pdfName: "user-report.pdf"
});

await file.createFileFromBuffer({ filename: "doc.txt", contentType: "text/plain" }, Buffer.from("Hello"));

// En supposant que vous avez un fichier modèle avec des espaces réservés comme :
// Facture pour : {d.customerName}
// Montant : {d.amount}
// Date : {d.date}

let data = {
  customerName: "John Doe",
  amount: 1500,
  date: "2025-01-15",
  items: [
    { product: "Widget A", quantity: 5, price: 100 },
    { product: "Widget B", quantity: 10, price: 50 }
  ]
};

// Remplir le modèle
let filledDocumentId = await SF.file.fillTemplate("64bfa28cfabc123...", data);
console.log("ID du document rempli:", filledDocumentId);

let result = await SF.utils.deleteFileById("60c72b2f9f1b2c3c8f3b8b0b");
// retourne: { deleted: 1 } (si le fichier a été supprimé)

let result = await SF.utils.deleteFileById("60c72b2f9f1b2c3c8f3b8b0c");
// retourne: { deleted: 0 } (s'il y a eu une erreur ou que le fichier n'a pas été trouvé)

await SF.sql.insertOne("610c0343f6ebc7ddcb49cc3b", "client", {
    code: 'MMA',
    codepostal: 225
})

await SF.sql.insertMany("610c0343f6ebc7ddcb49cc3b", "client", [{
    code: 'MMA',
    codepostal: 225
}])

await SF.sql.findOne("610c0343f6ebc7ddcb49cc3b", "client", "code='MGMT'")

await SF.sql.find("610c0343f6ebc7ddcb49cc3b", "client", "code='MGMT'")

await SF.sql.update("610c0343f6ebc7ddcb49cc3b", "client", "code='MDMS'", {
    code: 'CLEA'
})

 await SF.sql.delete("610c0343f6ebc7ddcb49cc3b", "client", "code='CLEA'")

 await SF.sql.count("610c0343f6ebc7ddcb49cc3b", "client", "code='CLEA'")

await SF.sql.execute('610c0343f6ebc7ddcb49cc3b', "DELETE FROM client WHERE code='KL'")

await SF.instance.launchProcess('610c0343f6ebc7ddcb49cc3b')

await SF.instance.findOne({ _id: ObjectId('610c0343f6ebc7ddcb49cc3b') })

await SF.instance.find({ status: 'running' })

await SF.instance.pendingTask('610c0343f6ebc7ddcb49cc3b')

await SF.instance.getMeasures('610c0343f6ebc7ddcb49cc3b')

let variables = {
  "variable1": "value1",
  "variable2": 1,
  "variable3": true
}
await SF.instance.validateTask('610c0343f6ebc7ddcb49cc3b',variables)

let data = {
  "variable1": "value1",
  "variable2": 1,
  "variable3": true
}
await SF.instance.updateVariablesById('610c0343f6ebc7ddcb49cc3b',data)

let result = await SF.utils.attachChildInstance(
  "661e9d8a1a2b2f7f8d3c4e1f",
  "661e9d9b2b5e2f8f8d3c5f0a",
  "step123"
);
// retourne: { done: true }

let instance = await SF.utils.getVariablesById("661e9d8a1a2b2f7f8d3c4e1f");
// retourne: Document d'instance complet

let instance = await SF.utils.getVariablesById("661e9d8a1a2b2f7f8d3c4e1f", { variables: 1 });
// retourne: { variables: {...} }

let result = await SF.instance.deleteInstanceById("661e9d8a1a2b2f7f8d3c4e1f");
// retourne: { done: true }

let result = await SF.instance.deleteManyInstances("661e9d8a1a2b2f7f8d3c4e1f", { status: "completed" });
// retourne: { done: true }

// Supprimer toutes les instances terminées avec nettoyage complet
let result = await SF.instance.deleteManyInstancesWithTasksAndHistories(
  "661e9d8a1a2b2f7f8d3c4e1f",
  { status: "completed" }
);
// retourne: { done: true }

// Supprimer toutes les instances antérieures à une certaine date
let result = await SF.instance.deleteManyInstancesWithTasksAndHistories(
  "661e9d8a1a2b2f7f8d3c4e1f",
  { createdAt: { $lt: new Date('2024-01-01') } }
);
// retourne: { done: true }

let result = await SF.utils.updateInstanceVariables("661e9d8a1a2b2f7f8d3c4e1f", {
  amount: 1500,
  dueDate: "2025-05-30"
});
// retourne: { done: true }

// Accéder aux méthodes directement depuis SF.softyTable
await SF.softyTable.list('tableId123', criteria);

// Lister toutes les lignes
let rows = await SF.softyTable.list('610c0343f6ebc7ddcb49cc3b');

// Lister avec filtres
let activeRows = await SF.softyTable.list(
  '610c0343f6ebc7ddcb49cc3b',
  { where: { status: 'active' } },
  50,
  0,
  'createdAt',
  -1
);

// Lister avec critères complexes
let rows = await SF.softyTable.list(
  '610c0343f6ebc7ddcb49cc3b',
  {
    where: { age: { $gte: 18 } },
    attributes: ['name', 'email', 'age']
  },
  20,
  0
);

// Compter toutes les lignes
let result = await SF.softyTable.count('610c0343f6ebc7ddcb49cc3b');
// retourne: { count: 150 }

// Compter avec filtre
let result = await SF.softyTable.count(
  '610c0343f6ebc7ddcb49cc3b',
  { where: { status: 'active' } }
);
// retourne: { count: 75 }

let newRow = await SF.softyTable.create(
  '610c0343f6ebc7ddcb49cc3b',
  {
    name: 'John Doe',
    email: 'john@example.com',
    age: 30,
    status: 'active'
  }
);

let newRows = await SF.softyTable.createMany(
  '610c0343f6ebc7ddcb49cc3b',
  [
    { name: 'John Doe', email: 'john@example.com', age: 30 },
    { name: 'Jane Smith', email: 'jane@example.com', age: 25 },
    { name: 'Bob Johnson', email: 'bob@example.com', age: 35 }
  ]
);

let row = await SF.softyTable.retrieve('610c0343f6ebc7ddcb49cc3b', '12345');

let updated = await SF.softyTable.update(
  '610c0343f6ebc7ddcb49cc3b',
  '12345',
  {
    status: 'inactive',
    updatedAt: new Date()
  }
);

// Mettre à jour toutes les lignes où le statut est 'pending'
let result = await SF.softyTable.updateMany(
  '610c0343f6ebc7ddcb49cc3b',
  { status: 'pending' },
  { status: 'active', processedAt: new Date() }
);

await SF.softyTable.delete('610c0343f6ebc7ddcb49cc3b', '12345');

// Supprimer toutes les lignes inactives
await SF.softyTable.deleteMany(
  '610c0343f6ebc7ddcb49cc3b',
  { status: 'inactive' }
);

// Supprimer les lignes antérieures à une certaine date
await SF.softyTable.deleteMany(
  '610c0343f6ebc7ddcb49cc3b',
  { createdAt: { $lt: new Date('2024-01-01') } }
);

// Supprimer toutes les lignes de la table
await SF.softyTable.clear('610c0343f6ebc7ddcb49cc3b');

let options = await SF.softyTable.getOptions(
  '610c0343f6ebc7ddcb49cc3b',
  'status_field'
);
// retourne: [{ label: 'Active', value: 'active' }, { label: 'Inactive', value: 'inactive' }]

// Lister tous les éléments liés
let relatedItems = await SF.softyTable.joinTableList(
  '610c0343f6ebc7ddcb49cc3b',
  'related_products'
);

// Lister avec filtres et pagination
let items = await SF.softyTable.joinTableList(
  '610c0343f6ebc7ddcb49cc3b',
  'related_products',
  { where: { category: 'electronics' } },
  20,
  0,
  'price',
  -1
);

let result = await SF.softyTable.joinTableCount(
  '610c0343f6ebc7ddcb49cc3b',
  'related_products'
);
// retourne: { count: 45 }

let result = await SF.softyTable.joinTableCount(
  '610c0343f6ebc7ddcb49cc3b',
  'related_products',
  { where: { category: 'electronics' } }
);
// retourne: { count: 12 }

// Exécuter une requête SELECT
let results = await SF.softyTable.execute(
  '610c0343f6ebc7ddcb49cc3b',
  'SELECT * FROM my_table WHERE status = :status',
  {
    replacements: { status: 'active' },
    type: 'SELECT'
  }
);

// Exécuter une requête personnalisée
let results = await SF.softyTable.execute(
  '610c0343f6ebc7ddcb49cc3b',
  'UPDATE my_table SET status = "processed" WHERE created_at < NOW() - INTERVAL 30 DAY',
  { type: 'UPDATE' }
);

let result = await SF.softyTable.migrate(
  '610c0343f6ebc7ddcb49cc3b',
  {
    // Configuration de migration
  }
);

await SF.task.findOne({ _id: ObjectId('610c0343f6ebc7ddcb49cc3b') })

await SF.task.find({ status: 'pending' })

await SF.task.deleteTaskById('610c0343f6ebc7ddcb49cc3b')

// Supprimer toutes les tâches avec le statut 'completed'
await SF.task.deleteMany({ status: 'completed' })

// Supprimer toutes les tâches pour une instance spécifique
await SF.task.deleteMany({ instanceId: ObjectId('610c0343f6ebc7ddcb49cc3b') })

await SF.task.deleteHistoryByTaskId('610c0343f6ebc7ddcb49cc3b')

await SF.task.deleteHistoryByInstanceId('610c0343f6ebc7ddcb49cc3b')

// Supprimer tous les enregistrements d'historique pour une action spécifique
await SF.task.deleteHistory({ action: 'task_completed' })

// Supprimer les enregistrements d'historique antérieurs à une certaine date
await SF.task.deleteHistory({ createdAt: { $lt: new Date('2024-01-01') } })

await SF.task.saveTask('610c0343f6ebc7ddcb49cc3b', {
  status: 'in-progress',
  assignee: 'user123'
})

await SF.task.updateTask('610c0343f6ebc7ddcb49cc3b', {
  status: 'completed',
  completedAt: new Date()
})