Method CreateSheets

backend/store/sheet.go:111–143

CreateSheets creates sheet blobs using content-addressed storage. Each sheet is identified by the SHA256 hash of its statement. Duplicate statements share the same blob (ON CONFLICT DO NOTHING).

(ctx context.Context, creates ...*SheetMessage)

// Each sheet is identified by the SHA256 hash of its statement.
// Duplicate statements share the same blob (ON CONFLICT DO NOTHING).
func (s *Store) CreateSheets(ctx context.Context, creates ...*SheetMessage) ([]*SheetMessage, error) {
	var statements []string
	var sha256s [][]byte

	for _, c := range creates {
		statements = append(statements, c.Statement)
		h := sha256.Sum256([]byte(c.Statement))
		c.Sha256 = hex.EncodeToString(h[:])
		sha256s = append(sha256s, h[:])
		c.Size = int64(len(c.Statement))
	}

	q := qb.Q().Space(`
		INSERT INTO sheet_blob (
			sha256,
			content
		) SELECT
		 	unnest(CAST(? AS BYTEA[])),
			unnest(CAST(? AS TEXT[]))
		ON CONFLICT DO NOTHING
	`, sha256s, statements)

	query, args, err := q.ToSQL()
	if err != nil {
		return nil, errors.Wrapf(err, "failed to build sql")
	}

	if _, err := s.GetDB().ExecContext(ctx, query, args...); err != nil {
		return nil, errors.Wrapf(err, "failed to exec")
	}

	return creates, nil
}

// HasSheets checks if all sheets exist by SHA256 hashes.
func (s *Store) HasSheets(ctx context.Context, sha256Hexes ...string) (bool, error) {