Function queueDocsBatchRequests

internal/cmd/batch.go:429–486

(ctx context.Context, flags *RootFlags, batchID, documentID, command, revisionID string, requests []*docs.Request, requireEmpty bool)

}

func queueDocsBatchRequests(ctx context.Context, flags *RootFlags, batchID, documentID, command, revisionID string, requests []*docs.Request, requireEmpty bool) (bool, error) {
	batchID = strings.TrimSpace(batchID)
	if batchID == "" {
		return false, nil
	}
	if err := validateDocsBatchIDArg(batchID); err != nil {
		return true, err
	}
	if len(requests) == 0 {
		return true, errors.New("no Docs requests to append")
	}
	account, err := requireAccount(flags)
	if err != nil {
		return true, err
	}
	client, err := resolveClientForEmail(ctx, account, flags)
	if err != nil {
		return true, err
	}
	store, err := newDocsBatchStore(ctx)
	if err != nil {
		return true, err
	}
	rawRequests, err := marshalDocsBatchRequests(requests)
	if err != nil {
		return true, err
	}
	total, err := store.Append(docsbatch.AppendOptions{
		BatchID: batchID,
		Command: command,
		Identity: docsbatch.Identity{
			Service:    docsbatch.ServiceDocs,
			DocumentID: documentID,
			Account:    account,
			Client:     client,
		},
		RevisionID:   revisionID,
		Requests:     rawRequests,
		RequireEmpty: requireEmpty,
	})
	if err != nil {
		return true, err
	}
	if outfmt.IsJSON(ctx) {
		err = outfmt.WriteJSON(ctx, stdoutWriter(ctx), map[string]any{
			"batch_id": batchID,
			"queued":   len(requests),
			"requests": total,
		})
	} else {
		out := ui.FromContext(ctx).Out()
		out.Linef("batch_id\t%s", batchID)
		out.Linef("queued\t%d", len(requests))
		out.Linef("requests\t%d", total)
	}

	return true, err
}