Function acceptUpstreamDML

packages/wl-sdk/src/commons/dml.generated.ts:215–247

(input: AcceptUpstreamInput)

 * fork completion, UPDATE wanted, INSERT stamp, UPDATE completion w/ stamp ref.
 */
export function acceptUpstreamDML(input: AcceptUpstreamInput): string[] {
  const tagsField = formatTagsJson(input.stamp.skillTags);
  const msgField = sqlStringOrNull(input.stamp.message);
  const hopField = sqlStringOrNull(input.hopUri);

  const valence = `{"quality": ${input.stamp.quality}, "reliability": ${input.stamp.reliability}}`;

  const deleteCompletion = `DELETE FROM completions WHERE wanted_id='${escapeSqlString(input.wantedId)}'`;

  const insertCompletion =
    `INSERT IGNORE INTO completions (id, wanted_id, completed_by, evidence, hop_uri, completed_at) ` +
    `VALUES ('${escapeSqlString(input.completionId)}', '${escapeSqlString(input.wantedId)}', ` +
    `'${escapeSqlString(input.completedBy)}', '${escapeSqlString(input.evidence)}', ${hopField}, NOW())`;

  const updateWanted =
    `UPDATE wanted SET status='completed', claimed_by='${escapeSqlString(input.completedBy)}', ` +
    `evidence_url='${escapeSqlString(input.evidence)}', updated_at=NOW() ` +
    `WHERE id='${escapeSqlString(input.wantedId)}'`;

  const insertStamp =
    `INSERT INTO stamps (id, author, subject, valence, confidence, severity, context_id, context_type, skill_tags, message, hop_uri, created_at) ` +
    `VALUES ('${escapeSqlString(input.stamp.id)}', '${escapeSqlString(input.rigHandle)}', ` +
    `'${escapeSqlString(input.stamp.subject)}', '${escapeSqlString(valence)}', 1.0, ` +
    `'${escapeSqlString(input.stamp.severity)}', '${escapeSqlString(input.completionId)}', 'completion', ` +
    `${tagsField}, ${msgField}, ${hopField}, NOW())`;

  const updateCompletion =
    `UPDATE completions SET validated_by='${escapeSqlString(input.rigHandle)}', ` +
    `stamp_id='${escapeSqlString(input.stamp.id)}', validated_at=NOW() ` +
    `WHERE id='${escapeSqlString(input.completionId)}'`;

  return [deleteCompletion, insertCompletion, updateWanted, insertStamp, updateCompletion];
}

// CloseUpstreamDML (commons.go:751)