Microsoft Teams

Copied!
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
import json

import requests
from functions.api import function
from functions.sources import get_source

SOURCE_ALIAS = "<source_alias>"
TENANT_ID = "<tenant_id>"
CLIENT_ID = "<client_id>"
TEAM_ID = "<team_id>"
CHANNEL_ID = "<channel_id>"


@function(sources=[SOURCE_ALIAS])
def list_channel_messages() -> str:
    source = get_source(SOURCE_ALIAS)
    session = requests.Session()
    proxy = source.get_https_proxy_uri()
    if proxy:
        session.proxies.update({"http": proxy, "https": proxy})

    token_response = session.post(
        f"https://login.microsoftonline.com/{TENANT_ID}/oauth2/v2.0/token",
        data={
            "client_id": CLIENT_ID,
            "client_secret": source.get_secret("OAuthClientSecret"),
            "scope": "https://graph.microsoft.com/.default",
            "grant_type": "client_credentials",
        },
        timeout=30,
    )
    token_response.raise_for_status()

    response = session.get(
        f"https://graph.microsoft.com/v1.0/teams/{TEAM_ID}/channels/{CHANNEL_ID}/messages",
        params={"$top": 20},
        headers={"Authorization": f"Bearer {token_response.json()['access_token']}"},
        timeout=30,
    )
    response.raise_for_status()

    messages = [
        {
            "id": message.get("id"),
            "createdDateTime": message.get("createdDateTime"),
            "webUrl": message.get("webUrl"),
        }
        for message in response.json().get("value", [])
    ]
    return json.dumps(messages)

Copied!
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
import { ExternalSystems, Function } from "@foundry/functions-api";
import { MicrosoftTeamsSource } from "@foundry/external-systems/sources";

const TENANT_ID = "<tenant_id>";
const CLIENT_ID = "<client_id>";
const TEAM_ID = "<team_id>";
const CHANNEL_ID = "<channel_id>";

export class TeamsGraphFunctions {
    @ExternalSystems({ sources: [MicrosoftTeamsSource] })
    @Function()
    public async listChannelMessages(): Promise<string> {
        const tokenResponse = await MicrosoftTeamsSource.fetch(
            `https://login.microsoftonline.com/${TENANT_ID}/oauth2/v2.0/token`,
            {
                method: "POST",
                headers: { "Content-Type": "application/x-www-form-urlencoded" },
                body: new URLSearchParams({
                    client_id: CLIENT_ID,
                    client_secret: MicrosoftTeamsSource.getSecret("OAuthClientSecret"),
                    scope: "https://graph.microsoft.com/.default",
                    grant_type: "client_credentials",
                }).toString(),
            },
        );
        if (!tokenResponse.ok) throw new Error(`Microsoft token exchange returned ${tokenResponse.status}`);
        const token = await tokenResponse.json() as { access_token: string };

        const response = await MicrosoftTeamsSource.fetch(
            `https://graph.microsoft.com/v1.0/teams/${TEAM_ID}/channels/${encodeURIComponent(CHANNEL_ID)}/messages?$top=20`,
            { headers: { Authorization: `Bearer ${token.access_token}` } },
        );
        if (!response.ok) throw new Error(`Microsoft Graph returned ${response.status}`);

        const payload = await response.json() as {
            value?: Array<{ id?: string; createdDateTime?: string; webUrl?: string }>;
        };
        return JSON.stringify((payload.value ?? []).map((message) => ({
            id: message.id,
            createdDateTime: message.createdDateTime,
            webUrl: message.webUrl,
        })));
    }
}

Copied!
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
import { getFetch, getSource } from "@palantir/functions-sources";

const SOURCE_RID = "<source_rid>";
const TENANT_ID = "<tenant_id>";
const CLIENT_ID = "<client_id>";
const TEAM_ID = "<team_id>";
const CHANNEL_ID = "<channel_id>";

export const config = { sources: [SOURCE_RID] };

export default async function listChannelMessages(): Promise<string> {
    const source = await getSource({ rid: SOURCE_RID });
    const clientSecret = source.secrets.OAuthClientSecret;
    if (!clientSecret) throw new Error("Add OAuthClientSecret to the source");
    const sourceFetch = await getFetch(source);

    const tokenResponse = await sourceFetch(
        `https://login.microsoftonline.com/${TENANT_ID}/oauth2/v2.0/token`,
        {
            method: "POST",
            headers: { "Content-Type": "application/x-www-form-urlencoded" },
            body: new URLSearchParams({
                client_id: CLIENT_ID,
                client_secret: clientSecret,
                scope: "https://graph.microsoft.com/.default",
                grant_type: "client_credentials",
            }).toString(),
        },
    );
    if (!tokenResponse.ok) throw new Error(`Microsoft token exchange returned ${tokenResponse.status}`);
    const token = (await tokenResponse.json()) as { access_token: string };

    const response = await sourceFetch(
        `https://graph.microsoft.com/v1.0/teams/${TEAM_ID}/channels/${encodeURIComponent(CHANNEL_ID)}/messages?$top=20`,
        { headers: { Authorization: `Bearer ${token.access_token}` } },
    );
    if (!response.ok) throw new Error(`Microsoft Graph returned ${response.status}`);

    const payload = (await response.json()) as {
        value?: Array<{ id?: string; createdDateTime?: string; webUrl?: string }>;
    };
    return JSON.stringify((payload.value ?? []).map((message) => ({
        id: message.id,
        createdDateTime: message.createdDateTime,
        webUrl: message.webUrl,
    })));
}

Copied!
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
import { getFetch, getSource } from "@palantir/functions-sources";

const SOURCE_RID = "<source_rid>";
const TEAM_ID = "<team_id>";
const CHANNEL_ID = "<channel_id>";

export const config = { sources: [SOURCE_RID] };

export default async function sendChannelMessage(text: string): Promise<string> {
    const source = await getSource({ rid: SOURCE_RID });
    const credentials = await source.sessionCredentials?.get();
    if (credentials?.type !== "oauth") throw new Error("Authorize the source first");
    const sourceFetch = await getFetch(source);

    const response = await sourceFetch(
        `https://graph.microsoft.com/v1.0/teams/${TEAM_ID}/channels/${encodeURIComponent(CHANNEL_ID)}/messages`,
        {
            method: "POST",
            headers: {
                Authorization: `Bearer ${credentials.accessToken}`,
                "Content-Type": "application/json",
            },
            body: JSON.stringify({ body: { content: text } }),
        },
    );
    if (!response.ok) throw new Error(`Microsoft Graph returned ${response.status}`);
    return ((await response.json()) as { id: string }).id;
}