Function triggerRevalidate

controller/proof_query.go:234–259

(proofID int64)

}

func triggerRevalidate(proofID int64) error {
	switch common.CurrentRuntime {
	case common.Runtimes.Standalone:
		// Revalidate it in a block way since this func will
		// be called under goroutine.
		// FIXME: basiclly duplicated to `cmd/lambda_worker.revalidate_single()`
		proof := model.Proof{}
		tx := model.DB.Preload("ProofChain").Preload("ProofChain.Previous").Where("id = ?", proofID).First(&proof)
		if tx.Error != nil {
			return xerrors.Errorf("%w", tx.Error)
		}
		return proof.Revalidate()
	case common.Runtimes.Lambda:
		// Use AWS SQS to send message to workers
		msg := types.QueueMessage{
			Action:  types.QueueActions.Revalidate,
			ProofID: proofID,
		}

		if err := sqs.Send(msg); err != nil {
			return xerrors.Errorf("Failed to send message to queue: %w", err)
		}
	}

	return nil
}