Method EncodePersistedObject

core/file.go:211–261

(ctx context.Context, cache dagql.PersistedObjectCache)

}

func (file *File) EncodePersistedObject(ctx context.Context, cache dagql.PersistedObjectCache) (dagql.PersistedObjectEncoding, error) {
	if file == nil {
		return dagql.PersistedObjectEncoding{}, fmt.Errorf("encode persisted file: nil file")
	}
	filePath := ""
	if file.File != nil {
		if peekedPath, ok := file.File.Peek(); ok {
			filePath = peekedPath
		}
	}
	services, err := encodePersistedServiceBindings(cache, "file", file.Services)
	if err != nil {
		return dagql.PersistedObjectEncoding{}, err
	}
	payload := persistedFilePayload{
		File:     filePath,
		Platform: file.Platform,
		Services: services,
	}
	if file.Snapshot != nil {
		if snapshot, ok := file.Snapshot.Peek(); ok && snapshot != nil {
			payload.Form = persistedFileFormSnapshot
			payloadJSON, err := json.Marshal(payload)
			if err != nil {
				return dagql.PersistedObjectEncoding{}, fmt.Errorf("marshal persisted file payload: %w", err)
			}
			return dagql.PersistedObjectEncoding{
				JSON: payloadJSON,
				SnapshotLinks: []dagql.PersistedSnapshotRefLink{{
					RefKey: snapshot.SnapshotID(),
					Role:   "snapshot",
				}},
			}, nil
		}
	}
	if file.Lazy != nil {
		payload.Form = persistedFileFormLazy
		lazyKind, lazyJSON, err := encodePersistedFileLazy(ctx, cache, file.Lazy)
		if err != nil {
			return dagql.PersistedObjectEncoding{}, err
		}
		payload.LazyKind = lazyKind
		payload.LazyJSON = lazyJSON
		payloadJSON, err := json.Marshal(payload)
		if err != nil {
			return dagql.PersistedObjectEncoding{}, fmt.Errorf("marshal persisted file payload: %w", err)
		}
		return encodePersistedObjectRawJSON(payloadJSON), nil
	}
	return dagql.PersistedObjectEncoding{}, fmt.Errorf("%w: encode persisted file: missing snapshot and lazy op", dagql.ErrPersistStateNotReady)
}

//nolint:dupl // symmetric with decodePersistedDirectoryWithSnapshotRole in directory.go; sharing hides type specifics
func decodePersistedFileWithSnapshotRole(ctx context.Context, dag *dagql.Server, resultID uint64, payload json.RawMessage, snapshotRole string) (*File, error) {