slack

Slack 🔗

post() 🔗

Post or edit the progress card. Returns the message ts.

With an empty ts it posts (chat.postMessage); with one it edits in place (chat.update). ONE message per run, edited — not a thread of new messages.

Best-effort by contract: a Slack outage logs and returns the ts it was given, and NEVER brings the pipeline down. A notification channel that can fail the build is a notification channel that gets removed.

Return Type

String !

Arguments

dagger -m github.com/wildbitca/daggerverse/slack@928b214a0dec70c7c68291365e26508b63fa8b92 call \
 post --token env:MYSECRET --channel string --body string --ts stringcontent_copy Copied! 

func (m *MyModule) Example(ctx context.Context, token *dagger.Secret, channel string, body string, ts string) string  {
	return dag.
			Slack().
			Post(ctx, token, channel, body, ts)
}content_copy Copied!

@function
async def example(token: dagger.Secret, channel: str, body: str, ts: str) -> str:
	return await (
		dag.slack()
		.post(token, channel, body, ts)
	)content_copy Copied!

@func()
async example(token: Secret, channel: string, body: string, ts: string): Promise<string> {
	return dag
		.slack()
		.post(token, channel, body, ts)
}content_copy Copied!

render() 🔗

Render the progress card. Pure — no container, no network.

The returned JSON carries metadata.event_type + event_payload, which is what readTrend reads on the NEXT run: Slack itself is the trend store, so there is no database to run.

Return Type

String !

Arguments

dagger -m github.com/wildbitca/daggerverse/slack@928b214a0dec70c7c68291365e26508b63fa8b92 call \
 render --title string --status string --meta string --items string --elapsed-ms integer --event-type string --metrics string --trend stringcontent_copy Copied! 

func (m *MyModule) Example(ctx context.Context, title string, status string, meta string, items string, elapsedMs int, eventType string, metrics string, trend string) string  {
	return dag.
			Slack().
			Render(ctx, title, status, meta, items, elapsedMs, eventType, metrics, trend)
}content_copy Copied!

@function
async def example(title: str, status: str, meta: str, items: str, elapsedms: int, eventtype: str, metrics: str, trend: str) -> str:
	return await (
		dag.slack()
		.render(title, status, meta, items, elapsedms, eventtype, metrics, trend)
	)content_copy Copied!

@func()
async example(title: string, status: string, meta: string, items: string, elapsedMs: number, eventType: string, metrics: string, trend: string): Promise<string> {
	return dag
		.slack()
		.render(title, status, meta, items, elapsedMs, eventType, metrics, trend)
}content_copy Copied!

readTrend() 🔗

Read the previous run’s metrics from Slack — the trend store is Slack itself.

Matches on event_type AND repo: event_type alone was not enough once two lanes of the same repo shared a series, and the comparison silently compared a five-emulator e2e against a Simulator build and printed a perfectly plausible, false “↑12m vs previous”.

cacheBust MUST vary per run (use the run id). Without it Dagger serves the previous exec from cache and every run reads the same stale trend — a network read cached is a network read that did not happen (Gotcha 2).

Best-effort: returns “” on any failure. No trend is a missing line on a card; a hard failure here would be a pipeline down because a chat app was slow.

Return Type

String !

Arguments

dagger -m github.com/wildbitca/daggerverse/slack@928b214a0dec70c7c68291365e26508b63fa8b92 call \
 read-trend --token env:MYSECRET --channel string --event-type string --repo string --cache-bust stringcontent_copy Copied! 

func (m *MyModule) Example(ctx context.Context, token *dagger.Secret, channel string, eventType string, repo string, cacheBust string) string  {
	return dag.
			Slack().
			Readtrend(ctx, token, channel, eventType, repo, cacheBust)
}content_copy Copied!

@function
async def example(token: dagger.Secret, channel: str, eventtype: str, repo: str, cachebust: str) -> str:
	return await (
		dag.slack()
		.readtrend(token, channel, eventtype, repo, cachebust)
	)content_copy Copied!

@func()
async example(token: Secret, channel: string, eventType: string, repo: string, cacheBust: string): Promise<string> {
	return dag
		.slack()
		.readTrend(token, channel, eventType, repo, cacheBust)
}content_copy Copied!

findCard() 🔗

Find the ts of the card a given run posted, by its metadata. Returns “” when there is none.

A card is identified by event_type + run_id + run_attempt, never by run_id alone: a re-run keeps the run id, and matching on it alone threads attempt 2’s detail under attempt 1’s card, which already says “FAILED”. An empty runAttempt matches any attempt and takes the newest, which is what a caller that does not know its attempt wants.

Only TOP-LEVEL messages are searched (conversations.history), because that is where a card lives; replies are not cards. include_all_metadata=true is not optional: without it Slack omits metadata and nothing ever matches.

⚠️ channel must be the channel ID (C…), not its name. chat.postMessage accepts a name, conversations.history does not, and answers channel_not_found, which this function reports as “no card”.

Return Type

String !

Arguments

dagger -m github.com/wildbitca/daggerverse/slack@928b214a0dec70c7c68291365e26508b63fa8b92 call \
 find-card --token env:MYSECRET --channel string --event-type string --run-id string --cache-bust string --run-attempt string --limit integercontent_copy Copied! 

func (m *MyModule) Example(ctx context.Context, token *dagger.Secret, channel string, eventType string, runId string, cacheBust string, runAttempt string, limit int) string  {
	return dag.
			Slack().
			Findcard(ctx, token, channel, eventType, runId, cacheBust, runAttempt, limit)
}content_copy Copied!

@function
async def example(token: dagger.Secret, channel: str, eventtype: str, runid: str, cachebust: str, runattempt: str, limit: int) -> str:
	return await (
		dag.slack()
		.findcard(token, channel, eventtype, runid, cachebust, runattempt, limit)
	)content_copy Copied!

@func()
async example(token: Secret, channel: string, eventType: string, runId: string, cacheBust: string, runAttempt: string, limit: number): Promise<string> {
	return dag
		.slack()
		.findCard(token, channel, eventType, runId, cacheBust, runAttempt, limit)
}content_copy Copied!

breakdown() 🔗

The closing detail, in the card’s THREAD: duration per step, the test table and the trend. Posted on ok AND on fail — a run that failed is the one whose detail somebody actually needs.

In the thread and not as a second channel message: the card is already where this run is being watched, and a loose message forces pairing them by eye.

Return Type

String !

Arguments

dagger -m github.com/wildbitca/daggerverse/slack@928b214a0dec70c7c68291365e26508b63fa8b92 call \
 breakdown --token env:MYSECRET --channel string --thread-ts string --status string --items string --elapsed-ms integer --metrics string --trend stringcontent_copy Copied! 

func (m *MyModule) Example(ctx context.Context, token *dagger.Secret, channel string, threadTs string, status string, items string, elapsedMs int, metrics string, trend string) string  {
	return dag.
			Slack().
			Breakdown(ctx, token, channel, threadTs, status, items, elapsedMs, metrics, trend)
}content_copy Copied!

@function
async def example(token: dagger.Secret, channel: str, threadts: str, status: str, items: str, elapsedms: int, metrics: str, trend: str) -> str:
	return await (
		dag.slack()
		.breakdown(token, channel, threadts, status, items, elapsedms, metrics, trend)
	)content_copy Copied!

@func()
async example(token: Secret, channel: string, threadTs: string, status: string, items: string, elapsedMs: number, metrics: string, trend: string): Promise<string> {
	return dag
		.slack()
		.breakdown(token, channel, threadTs, status, items, elapsedMs, metrics, trend)
}content_copy Copied!

threadReply() 🔗

Reply in the card’s thread. The per-repo detail (which flows are red, which .dart file broke) is posted with this — the engine knows nothing about flows.

Return Type

String !

Arguments

dagger -m github.com/wildbitca/daggerverse/slack@928b214a0dec70c7c68291365e26508b63fa8b92 call \
 thread-reply --token env:MYSECRET --channel string --thread-ts string --text string --blocks stringcontent_copy Copied! 

func (m *MyModule) Example(ctx context.Context, token *dagger.Secret, channel string, threadTs string, text string, blocks string) string  {
	return dag.
			Slack().
			Threadreply(ctx, token, channel, threadTs, text, blocks)
}content_copy Copied!

@function
async def example(token: dagger.Secret, channel: str, threadts: str, text: str, blocks: str) -> str:
	return await (
		dag.slack()
		.threadreply(token, channel, threadts, text, blocks)
	)content_copy Copied!

@func()
async example(token: Secret, channel: string, threadTs: string, text: string, blocks: string): Promise<string> {
	return dag
		.slack()
		.threadReply(token, channel, threadTs, text, blocks)
}content_copy Copied!

failureDetail() 🔗

The error block a failed run posts in its thread before the breakdown.

Truncates from the END: the last 2600 characters of a stack trace are the ones that say what broke; the first 2600 are the ones that say the build started.

Return Type

String !

Arguments

dagger -m github.com/wildbitca/daggerverse/slack@928b214a0dec70c7c68291365e26508b63fa8b92 call \
 failure-detail --token env:MYSECRET --channel string --thread-ts string --stage string --detail stringcontent_copy Copied! 

func (m *MyModule) Example(ctx context.Context, token *dagger.Secret, channel string, threadTs string, stage string, detail string) string  {
	return dag.
			Slack().
			Failuredetail(ctx, token, channel, threadTs, stage, detail)
}content_copy Copied!

@function
async def example(token: dagger.Secret, channel: str, threadts: str, stage: str, detail: str) -> str:
	return await (
		dag.slack()
		.failuredetail(token, channel, threadts, stage, detail)
	)content_copy Copied!

@func()
async example(token: Secret, channel: string, threadTs: string, stage: string, detail: string): Promise<string> {
	return dag
		.slack()
		.failureDetail(token, channel, threadTs, stage, detail)
}content_copy Copied!