Routing

1
Deno.serve(async (req) => {
2
  const { method, url } = req
3
  const { pathname } = new URL(url)
4
5
  // Route based on method and path
6
  if (method === 'GET' && pathname === '/users') {
7
    return getAllUsers()
8
  } else if (method === 'POST' && pathname === '/users') {
9
    return createUser(req)
10
  }
11
12
  return new Response('Not found', { status: 404 })
13
})

1
// Follow this setup guide to integrate the Deno language server with your editor:
2
// https://deno.land/manual/getting_started/setup_your_environment
3
// This enables autocomplete, go to definition, etc.
4
5
import { createClient, SupabaseClient } from 'npm:supabase-js@2'
6
7
const corsHeaders = {
8
  'Access-Control-Allow-Origin': '*',
9
  'Access-Control-Allow-Headers': 'authorization, x-client-info, apikey',
10
  'Access-Control-Allow-Methods': 'POST, GET, OPTIONS, PUT, DELETE',
11
}
12
13
interface Task {
14
  name: string
15
  status: number
16
}
17
18
async function getTask(supabaseClient: SupabaseClient, id: string) {
19
  const { data: task, error } = await supabaseClient.from('tasks').select('*').eq('id', id)
20
  if (error) throw error
21
22
  return new Response(JSON.stringify({ task }), {
23
    headers: { ...corsHeaders, 'Content-Type': 'application/json' },
24
    status: 200,
25
  })
26
}
27
28
async function getAllTasks(supabaseClient: SupabaseClient) {
29
  const { data: tasks, error } = await supabaseClient.from('tasks').select('*')
30
  if (error) throw error
31
32
  return new Response(JSON.stringify({ tasks }), {
33
    headers: { ...corsHeaders, 'Content-Type': 'application/json' },
34
    status: 200,
35
  })
36
}
37
38
async function deleteTask(supabaseClient: SupabaseClient, id: string) {
39
  const { error } = await supabaseClient.from('tasks').delete().eq('id', id)
40
  if (error) throw error
41
42
  return new Response(JSON.stringify({}), {
43
    headers: { ...corsHeaders, 'Content-Type': 'application/json' },
44
    status: 200,
45
  })
46
}
47
48
async function updateTask(supabaseClient: SupabaseClient, id: string, task: Task) {
49
  const { error } = await supabaseClient.from('tasks').update(task).eq('id', id)
50
  if (error) throw error
51
52
  return new Response(JSON.stringify({ task }), {
53
    headers: { ...corsHeaders, 'Content-Type': 'application/json' },
54
    status: 200,
55
  })
56
}
57
58
async function createTask(supabaseClient: SupabaseClient, task: Task) {
59
  const { error } = await supabaseClient.from('tasks').insert(task)
60
  if (error) throw error
61
62
  return new Response(JSON.stringify({ task }), {
63
    headers: { ...corsHeaders, 'Content-Type': 'application/json' },
64
    status: 200,
65
  })
66
}
67
68
Deno.serve(async (req) => {
69
  const { url, method } = req
70
71
  // This is needed if you're planning to invoke your function from a browser.
72
  if (method === 'OPTIONS') {
73
    return new Response('ok', { headers: corsHeaders })
74
  }
75
76
  try {
77
    // Create a Supabase client with the Auth context of the logged in user.
78
    const supabaseClient = createClient(
79
      // Supabase API URL - env var exported by default.
80
      Deno.env.get('SUPABASE_URL') ?? '',
81
      // Supabase API ANON KEY - env var exported by default.
82
      Deno.env.get('SUPABASE_ANON_KEY') ?? '',
83
      // Create client with Auth context of the user that called the function.
84
      // This way your row-level-security (RLS) policies are applied.
85
      {
86
        global: {
87
          headers: { Authorization: req.headers.get('Authorization')! },
88
        },
89
      }
90
    )
91
92
    // For more details on URLPattern, check https://developer.mozilla.org/en-US/docs/Web/API/URL_Pattern_API
93
    const taskPattern = new URLPattern({ pathname: '/restful-tasks/:id' })
94
    const matchingPath = taskPattern.exec(url)
95
    const id = matchingPath ? matchingPath.pathname.groups.id : null
96
97
    let task = null
98
    if (method === 'POST' || method === 'PUT') {
99
      const body = await req.json()
100
      task = body.task
101
    }
102
103
    // call relevant method based on method and id
104
    switch (true) {
105
      case id && method === 'GET':
106
        return getTask(supabaseClient, id as string)
107
      case id && method === 'PUT':
108
        return updateTask(supabaseClient, id as string, task)
109
      case id && method === 'DELETE':
110
        return deleteTask(supabaseClient, id as string)
111
      case method === 'POST':
112
        return createTask(supabaseClient, task)
113
      case method === 'GET':
114
        return getAllTasks(supabaseClient)
115
      default:
116
        return getAllTasks(supabaseClient)
117
    }
118
  } catch (error) {
119
    console.error(error)
120
121
    return new Response(JSON.stringify({ error: error.message }), {
122
      headers: { ...corsHeaders, 'Content-Type': 'application/json' },
123
      status: 400,
124
    })
125
  }
126
})