Function GetCommit

db/api/api.go:178–212

(ctx context.Context, api Interface, pool, revision string)

}

func GetCommit(ctx context.Context, api Interface, pool, revision string) (*commits.Commit, error) {
	poolID, err := api.PoolID(ctx, pool)
	if err != nil {
		return nil, err
	}
	commit, err := dbid.ParseID(revision)
	if err != nil {
		// LookupBranchByName(ctx
		if commit, err = api.CommitObject(ctx, poolID, revision); err != nil {
			return nil, err
		}
	}
	b := newBuffer(commits.Commit{})
	query := fmt.Sprintf("from %q:log | where id == 0x%s", poolID, idToHex(commit))
	q, err := api.Query(ctx, srcfiles.Plain(query))
	if err != nil {
		return nil, err
	}
	defer q.Pull(true)
	if err := vio.Copy(b, q); err != nil {
		return nil, err
	}
	switch len(b.results) {
	case 0:
		return nil, fmt.Errorf("%s: commit not found", commit)
	case 1:
		commit, ok := b.results[0].(*commits.Commit)
		if !ok {
			return nil, fmt.Errorf("internal error: branch record has wrong type: %T", b.results[0])
		}
		return commit, nil
	default:
		return nil, fmt.Errorf("internal error: multiple commits found with same id: %s", commit)
	}
}

func idToHex(id ksuid.KSUID) string {
	return hex.EncodeToString(id.Bytes())