Method EncodePersistedObject

core/git.go:253–294

(ctx context.Context, cache dagql.PersistedObjectCache)

}

func (repo *GitRepository) EncodePersistedObject(ctx context.Context, cache dagql.PersistedObjectCache) (dagql.PersistedObjectEncoding, error) {
	if repo == nil {
		return dagql.PersistedObjectEncoding{}, fmt.Errorf("encode persisted git repository: nil repository")
	}
	remoteJSON, err := json.Marshal(repo.Remote)
	if err != nil {
		return dagql.PersistedObjectEncoding{}, fmt.Errorf("marshal persisted git repository remote: %w", err)
	}
	payload := persistedGitRepositoryPayload{
		DiscardGitDir: repo.DiscardGitDir,
		RemoteJSON:    remoteJSON,
	}
	switch backend := repo.Backend.(type) {
	case *LocalGitRepository:
		dirID, err := encodePersistedObjectRef(cache, backend.Directory, "git repository directory")
		if err != nil {
			return dagql.PersistedObjectEncoding{}, err
		}
		payload.Form = persistedGitRepositoryFormLocal
		payload.Local = &persistedLocalGitRepositoryPayload{
			DirectoryResultID: dirID,
		}
	case *RemoteGitRepository:
		if backend.URL == nil {
			return dagql.PersistedObjectEncoding{}, fmt.Errorf("encode persisted git repository: remote backend missing URL")
		}
		payload.Form = persistedGitRepositoryFormRemote
		payload.Remote = &persistedRemoteGitRepositoryPayload{
			URL:           backend.URL.String(),
			SSHKnownHosts: backend.SSHKnownHosts,
			AuthUsername:  backend.AuthUsername,
			Platform:      backend.Platform,
		}
	default:
		return dagql.PersistedObjectEncoding{}, fmt.Errorf("encode persisted git repository: unsupported backend %T", repo.Backend)
	}
	payloadJSON, err := json.Marshal(payload)
	if err != nil {
		return dagql.PersistedObjectEncoding{}, fmt.Errorf("marshal persisted git repository payload: %w", err)
	}
	return encodePersistedObjectRawJSON(payloadJSON), nil
}

func (*GitRepository) DecodePersistedObject(ctx context.Context, dag *dagql.Server, resultID uint64, _ *dagql.ResultCall, payload json.RawMessage) (dagql.Typed, error) {
	var persisted persistedGitRepositoryPayload