🐛 Refresh token won't implement

components/account/AuthTicketTable.vue

@@ -87,6 +87,8 @@
 </template>
 
 <script setup lang="ts">
+import { solarFetch } from "~/utils/request"
+
 const config = useRuntimeConfig()
 
 const error = ref<string | null>(null)
@@ -123,15 +125,12 @@ async function readTickets({ page, itemsPerPage }: { page?: number; itemsPerPage
   if (page) pagination.tickets.page = page
 
   reverting.sessions = true
-  const res = await fetch(
-    `${config.public.solarNetworkApi}/cgi/auth/users/me/tickets?` +
+  const res = await solarFetch(
+    "/cgi/auth/users/me/tickets?" +
     new URLSearchParams({
       take: pagination.tickets.pageSize.toString(),
       offset: ((pagination.tickets.page - 1) * pagination.tickets.pageSize).toString(),
     }),
-    {
-      headers: { Authorization: `Bearer ${useAtk().value}` },
-    },
   )
   if (res.status !== 200) {
     error.value = await res.text()
@@ -148,15 +147,12 @@ async function readEvents({ page, itemsPerPage }: { page?: number; itemsPerPage?
   if (page) pagination.events.page = page
 
   reverting.events = true
-  const res = await fetch(
-    `${config.public.solarNetworkApi}/cgi/auth/users/me/events?` +
+  const res = await solarFetch(
+    "/cgi/auth/users/me/events?" +
     new URLSearchParams({
       take: pagination.events.pageSize.toString(),
       offset: ((pagination.events.page - 1) * pagination.events.pageSize).toString(),
     }),
-    {
-      headers: { Authorization: `Bearer ${useAtk().value}` },
-    },
   )
   if (res.status !== 200) {
     error.value = await res.text()
@@ -172,9 +168,8 @@ Promise.all([readTickets({}), readEvents({})])
 
 async function killTicket(item: any) {
   reverting.sessions = true
-  const res = await fetch(`${config.public.solarNetworkApi}/cgi/auth/users/me/tickets/${item.id}`, {
+  const res = await solarFetch(`/cgi/auth/users/me/tickets/${item.id}`, {
     method: "DELETE",
-    headers: { Authorization: `Bearer ${useAtk().value}` },
   })
   if (res.status !== 200) {
     error.value = await res.text()

components/auth/AuthenticateCompleted.vue

@@ -16,7 +16,6 @@
 <script setup lang="ts">
 import { onMounted, ref } from "vue"
 import { useRoute, useRouter } from "vue-router"
-import { setTokenSet } from "~/stores/userinfo"
 
 const config = useRuntimeConfig()
 
@@ -53,7 +52,7 @@ async function getToken(tk: string) {
     throw new Error(err)
   } else {
     const out = await res.json()
-    setTokenSet(out["access_token"], out["refresh_token"])
+    auth.setTokenSet(out["access_token"], out["refresh_token"])
     error.value = null
   }
 }

pages/auth/authorize.vue

@@ -69,6 +69,7 @@
 
 <script setup lang="ts">
 import { ref } from "vue"
+import { solarFetch } from "~/utils/request"
 
 definePageMeta({
   middleware: ["auth"],
@@ -86,9 +87,7 @@ const metadata = ref<any>(null)
 const panel = ref("confirm")
 
 async function tryAuthorize() {
-  const res = await fetch(`${config.public.solarNetworkApi}/cgi/auth/auth/o/authorize` + window.location.search, {
-    headers: { Authorization: `Bearer ${useAtk().value}` },
-  })
+  const res = await solarFetch(`/cgi/auth/auth/o/authorize${window.location.search}`)
 
   if (res.status !== 200) {
     error.value = await res.text()
@@ -117,9 +116,8 @@ function decline() {
 
 async function approve() {
   loading.value = true
-  const res = await fetch(`${config.public.solarNetworkApi}/cgi/auth/auth/o/authorize` + window.location.search, {
+  const res = await solarFetch(`/cgi/auth/auth/o/authorize${window.location.search}`, {
     method: "POST",
-    headers: { Authorization: `Bearer ${useAtk().value}` },
   })
 
   if (res.status !== 200) {

stores/userinfo.ts

@@ -1,5 +1,6 @@
 import { defineStore } from "pinia"
 import { ref } from "vue"
+import { solarFetch } from "~/utils/request"
 
 export interface Userinfo {
   isLoggedIn: boolean
@@ -21,11 +22,6 @@ export function useRtk() {
   return useCookie("__hydrogen_rtk", { watch: "shallow" })
 }
 
-export function setTokenSet(atk: string, rtk: string) {
-  useAtk().value = atk
-  useRtk().value = rtk
-}
-
 export function useLoggedInState() {
   return computed(() => useAtk().value != null)
 }
@@ -34,6 +30,40 @@ export const useUserinfo = defineStore("userinfo", () => {
   const userinfo = ref(defaultUserinfo)
   const isReady = ref(false)
 
+  const lastRefreshedAt = ref<Date | null>(null)
+
+  function setTokenSet(atk: string, rtk: string) {
+    lastRefreshedAt.value = new Date()
+    useAtk().value = atk
+    useRtk().value = rtk
+  }
+
+  async function getAtk() {
+    if (lastRefreshedAt.value != null && Math.floor(Math.abs(Date.now() - lastRefreshedAt.value.getTime()) / 60000) < 3) {
+      return useAtk().value
+    }
+
+    const config = useRuntimeConfig()
+
+    const res = await fetch(`${config.public.solarNetworkApi}/cgi/auth/auth/token`, {
+      method: "POST",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify({
+        refresh_token: useRtk().value,
+        grant_type: "refresh_token",
+      }),
+    })
+    if (res.status !== 200) {
+      const err = await res.text()
+      throw new Error(err)
+    } else {
+      const out = await res.json()
+      console.log("[PASSPORT] Access token has been refreshed now.")
+      setTokenSet(out["access_token"], out["refresh_token"])
+      return out["access_token"]
+    }
+  }
+
   async function readProfiles() {
     if (!useLoggedInState().value) {
       isReady.value = true
@@ -41,9 +71,7 @@ export const useUserinfo = defineStore("userinfo", () => {
 
     const config = useRuntimeConfig()
 
-    const res = await fetch(`${config.public.solarNetworkApi}/cgi/auth/users/me`, {
-      headers: { Authorization: `Bearer ${useAtk().value}` },
-    })
+    const res = await solarFetch("/cgi/auth/users/me")
 
     if (res.status !== 200) {
       return
@@ -59,5 +87,5 @@ export const useUserinfo = defineStore("userinfo", () => {
     }
   }
 
-  return { userinfo, isReady, readProfiles }
+  return { userinfo, lastRefreshedAt, isReady, setTokenSet, getAtk, readProfiles }
 })

utils/request.ts

@@ -0,0 +1,12 @@
+export async function solarFetch(input: string | URL | globalThis.Request, init?: RequestInit) {
+  const auth = useUserinfo()
+  const config = useRuntimeConfig()
+
+  return await fetch(`${config.public.solarNetworkApi}${input}`, {
+    ...init,
+    headers: {
+      ...init?.headers,
+      "Authorization": `Bearer ${await auth.getAtk()}`,
+    },
+  })
+}