use cast progress from points

.env.example

@@ -1,3 +1,6 @@
+NEXT_PUBLIC_TEST=true
+NEXT_PUBLIC_PRIVY_APP_ID=
+PRIVATE_KEY=
 NEXT_PUBLIC_NEYNAR_CLIENT_ID=
 NEYNAR_CLIENT_ID=
 NEYNAR_API_KEY=

.eslintrc.json

@@ -19,7 +19,8 @@
     "eslint:recommended",
     "plugin:@typescript-eslint/recommended",
     "plugin:import/recommended",
-    "prettier"
+    "prettier",
+    "plugin:@tanstack/eslint-plugin-query/recommended"
   ],
   "rules": {
     "no-prototype-builtins": "off",

app/(feeds)/[username]/page.tsx

@@ -13,8 +13,7 @@ export default function ProfileHome() {
   const tab = useSearchParams().get('tab');
   const { loading, userStakes } = useUserStakes(tab, profile?.fid);
 
-  if (tab === 'stakes')
-    return loading ? <Loader /> : <UserStakes stakes={userStakes} />;
+  if (tab === 'stakes') return loading ? <Loader /> : <UserStakes stakes={userStakes} />;
 
   return <Feeds />;
-}
+}

app/(feeds)/channel/[channelId]/page.tsx

@@ -1,4 +1,4 @@
-import Feeds from '@/app/(feeds)/feeds';
+import ChannelPage from '@/components/ChannelPage';
 import { CHANNELS } from '@/lib/consts';
 
 export async function generateStaticParams() {
@@ -8,5 +8,5 @@ export async function generateStaticParams() {
 }
 
 export default function Channel() {
-  return <Feeds />;
+  return <ChannelPage />;
 }

app/(feeds)/layout.tsx

@@ -6,28 +6,19 @@ import { Sheet, SheetContent } from '@/components/ui/sheet';
 import { useUi } from '@/providers/UiProvider';
 import Header from '@/components/Header';
 import GlobalPlayer from '@/components/GlobalPlayer';
-import CreatePost from '@/components/CreatePost';
-import { useNeynarProvider } from '@/providers/NeynarProvider';
 import FeedProvider from '@/providers/FeedProvider';
 import ProfileProvider from '@/providers/ProfileProvider';
-import { useParams } from 'next/navigation';
-import TipsList from '@/components/TipsList';
 import StakeProvider from '@/providers/StakeProvider';
-import { cn } from '@/lib/utils';
-import ChannelHeader from '@/components/Header/ChannelHeader';
 
 export default function FeedLayout({ children }: { children: ReactNode }) {
   const { menuOpen, setMenuOpen } = useUi();
-  const { username, channelId } = useParams();
-  const { user } = useNeynarProvider();
-  const enableMaxWidth = !channelId && !username;
+  const { setIsCastPostOpen } = useUi();
 
   return (
     <ProfileProvider>
       <FeedProvider>
         <StakeProvider>
-          <TipsList />
-          <div className="flex grow">
+          <div className="flex h-screen">
             <meta property="of:accepts:xmtp" content="2024-02-01" />
             <nav className="md:hidden">
               <Sheet open={menuOpen} onOpenChange={setMenuOpen}>
@@ -41,19 +32,22 @@ export default function FeedLayout({ children }: { children: ReactNode }) {
               <Sidebar />
             </nav>
 
-            <main className="flex grow flex-col">
-              {!channelId && <Header />}
-              <div className="h-0 grow">
-                <div id="feed-container" className='size-full'>
-                  {channelId && <ChannelHeader />}
-                  <div className={cn('mt-4 container space-y-6', { 'max-w-3xl': enableMaxWidth })}>
-                    {user && !username && !channelId && <CreatePost />}
-                    {children}
-                  </div>
+            <main className="flex flex-col h-full flex-col overflow-hidden w-full">
+              <Header />
+              <div className="h-0 grow overflow-y-hidden">
+                <div id="feed-container" className="size-full px-6 mt-4 space-y-6">
+                  {children}
                 </div>
               </div>
             </main>
           </div>
+          <button
+            type="button"
+            className="bg-blue fixed z-40 bottom-4 right-4 text-white text-[32px] w-16 h-16 rounded-full"
+            onClick={() => setIsCastPostOpen(true)}
+          >
+            +
+          </button>
           <GlobalPlayer />
         </StakeProvider>
       </FeedProvider>

app/api/channel/details/route.ts

@@ -1,5 +1,5 @@
-import supabase from "@/lib/supabase/serverClient";
-import { NextRequest } from "next/server";
+import supabase from '@/lib/supabase/serverClient';
+import { NextRequest } from 'next/server';
 
 export async function GET(req: NextRequest) {
   const channelId = req.nextUrl.searchParams.get('channelId');
@@ -16,20 +16,20 @@ export async function GET(req: NextRequest) {
         .limit(1)
         .single(),
       supabase.rpc('get_channel_tips_balance', {
-        p_channelId: channelId
+        p_channelId: channelId,
       }),
       supabase
         .from('channel_stake_stats')
         .select('stakers,staked')
         .eq('channelId', channelId)
-        .single()
+        .single(),
     ]);
 
     return Response.json({
       message: 'success',
       topSong: topSong.data,
       staking: stakeStats.data,
-      balance: balance.data ?? 0
+      balance: balance.data ?? 0,
     });
   } catch (error) {
     console.error(error);
@@ -40,4 +40,4 @@ export async function GET(req: NextRequest) {
 
 export const dynamic = 'force-dynamic';
 export const fetchCache = 'force-no-store';
-export const revalidate = 0;
+export const revalidate = 0;

app/api/channel/stake/route.ts

@@ -14,10 +14,9 @@ export async function GET(req: NextRequest) {
 
     const user = await getUser(Number(fid));
 
-    const stakedAmount = Math.abs(await getStackPoints(
-      user.verifications,
-      eventStakeChannelFid(channelId, user.fid)
-    ));
+    const stakedAmount = Math.abs(
+      await getStackPoints(user.verifications, eventStakeChannelFid(channelId, user.fid)),
+    );
 
     return Response.json({ message: 'success', stakedAmount });
   } catch (error) {

app/api/channel/stats/route.ts

@@ -1,7 +1,7 @@
-import sortChannels from "@/lib/sortChannels";
-import getChannelStats from "@/lib/supabase/getChannelStats";
-import getFidChannelStats from "@/lib/supabase/getFidChannelStats";
-import { NextRequest } from "next/server";
+import sortChannels from '@/lib/sortChannels';
+import getChannelStats from '@/lib/supabase/getChannelStats';
+import getFidChannelStats from '@/lib/supabase/getFidChannelStats';
+import { NextRequest } from 'next/server';
 
 export async function GET(req: NextRequest) {
   const applyChannelFilter = req.nextUrl.searchParams.get('apply_channel_filter');
@@ -17,7 +17,9 @@ export async function GET(req: NextRequest) {
       console.log('channelStats count', channelStats.length);
 
       const allChannelStats = sortChannels(channelStats);
-      const channels = onlyChannelIds ? allChannelStats.map(channel => channel.channelId) : allChannelStats;
+      const channels = onlyChannelIds
+        ? allChannelStats.map((channel) => channel.channelId)
+        : allChannelStats;
 
       return Response.json({ message: 'success', channels });
     }

app/api/channel/weeklyAirdrop/route.ts

@@ -1,4 +1,4 @@
-import getChannelWeeklyAirdropData from "@/lib/sonata/channelWeeklyAirdrop/getChannelWeeklyAirdropData";
+import getChannelWeeklyAirdropData from '@/lib/sonata/channelWeeklyAirdrop/getChannelWeeklyAirdropData';
 
 export async function GET() {
   try {
@@ -11,4 +11,4 @@ export async function GET() {
   }
 }
 
-export const dynamic = 'force-dynamic';
+export const dynamic = 'force-dynamic';

app/api/jobs/channels/route.ts

@@ -1,12 +1,12 @@
-import distributeChannelStakerWeeklyAirdropAndTips from "@/lib/sonata/channelWeeklyAirdrop/distributeChannelStakerWeeklyAirdropAndTips";
-import distributeChannelWeeklyAirdrop from "@/lib/sonata/channelWeeklyAirdrop/distributeChannelWeeklyAirdrop";
-import sortChannels from "@/lib/sortChannels";
-import { stack } from "@/lib/stack/client";
-import { eventTipChannel } from "@/lib/stack/events";
-import getDaysChannelTotalTips from "@/lib/stack/getDaysChannelTotalTips";
-import getChannelStats from "@/lib/supabase/getChannelStats";
-import supabase from "@/lib/supabase/serverClient";
-import { NextRequest } from "next/server";
+import distributeChannelStakerWeeklyAirdropAndTips from '@/lib/sonata/channelWeeklyAirdrop/distributeChannelStakerWeeklyAirdropAndTips';
+import distributeChannelWeeklyAirdrop from '@/lib/sonata/channelWeeklyAirdrop/distributeChannelWeeklyAirdrop';
+import sortChannels from '@/lib/sortChannels';
+import { stack } from '@/lib/stack/client';
+import { eventTipChannel } from '@/lib/stack/events';
+import getDaysChannelTotalTips from '@/lib/stack/getDaysChannelTotalTips';
+import getChannelStats from '@/lib/supabase/getChannelStats';
+import supabase from '@/lib/supabase/serverClient';
+import { NextRequest } from 'next/server';
 
 export async function GET(req: NextRequest) {
   const TOP_CHANNELS = 10;
@@ -24,34 +24,39 @@ export async function GET(req: NextRequest) {
     const sortedChannels = sortChannels(channelStats);
     sortedChannels.splice(TOP_CHANNELS);
 
-    const results = await Promise.all(sortedChannels.map(async (channel) => {
-      const channelId = channel.channelId;
+    const results = await Promise.all(
+      sortedChannels.map(async (channel) => {
+        const channelId = channel.channelId;
 
-      const balance = channel.staked ? await getDaysChannelTotalTips(channelId, 7) : 0;
-      const TIPS = channel.staked && (balance > 0) ? Math.floor(balance / 2) : 0;
-      const CHANNEL_AIRDROP = channel.staked ? Math.floor(AIRDROP_AMOUNT / 2) : AIRDROP_AMOUNT;
-      const STAKERS_AIRDROP = channel.staked ? TIPS + CHANNEL_AIRDROP : 0;
+        const balance = channel.staked ? await getDaysChannelTotalTips(channelId, 7) : 0;
+        const TIPS = channel.staked && balance > 0 ? Math.floor(balance / 2) : 0;
+        const CHANNEL_AIRDROP = channel.staked ? Math.floor(AIRDROP_AMOUNT / 2) : AIRDROP_AMOUNT;
+        const STAKERS_AIRDROP = channel.staked ? TIPS + CHANNEL_AIRDROP : 0;
 
-      const { account } = await distributeChannelWeeklyAirdrop(channel, CHANNEL_AIRDROP);
+        const { account } = await distributeChannelWeeklyAirdrop(channel, CHANNEL_AIRDROP);
 
-      if (STAKERS_AIRDROP) await distributeChannelStakerWeeklyAirdropAndTips(STAKERS_AIRDROP, channelId);
+        if (STAKERS_AIRDROP)
+          await distributeChannelStakerWeeklyAirdropAndTips(STAKERS_AIRDROP, channelId);
 
-      if (TIPS) {
-        const [result] = await Promise.all([
-          stack.track(eventTipChannel(channelId), { account, points: -TIPS }),
-          supabase.from('channel_tips_activity_log').insert({ amount: -TIPS, channelId, channelAddress: account })
-        ]);
-        if (!result?.success) console.error(`${channelId} tip deduction failed`);
-        console.log('distributeChannelTip', channelId, TIPS);
-      }
+        if (TIPS) {
+          const [result] = await Promise.all([
+            stack.track(eventTipChannel(channelId), { account, points: -TIPS }),
+            supabase
+              .from('channel_tips_activity_log')
+              .insert({ amount: -TIPS, channelId, channelAddress: account }),
+          ]);
+          if (!result?.success) console.error(`${channelId} tip deduction failed`);
+          console.log('distributeChannelTip', channelId, TIPS);
+        }
 
-      return {
-        channelId,
-        channelAirdropAmount: CHANNEL_AIRDROP,
-        channelTips: TIPS,
-        stakersAirdropAmount: STAKERS_AIRDROP
-      };
-    }));
+        return {
+          channelId,
+          channelAirdropAmount: CHANNEL_AIRDROP,
+          channelTips: TIPS,
+          stakersAirdropAmount: STAKERS_AIRDROP,
+        };
+      }),
+    );
 
     return Response.json({ message: 'success', topChannels: results });
   } catch (error) {
@@ -62,4 +67,4 @@ export async function GET(req: NextRequest) {
 
 export const dynamic = 'force-dynamic';
 export const fetchCache = 'force-no-store';
-export const revalidate = 0;
+export const revalidate = 0;

app/api/jobs/updateHypersub/route.ts

@@ -1,7 +1,6 @@
 import processTipsBatch from '@/lib/hypersub/processTipsBatch';
 import forEachTableRowsBatch from '@/lib/supabase/forEachTableRowsBatch';
 
-
 export async function GET(): Promise<Response> {
   try {
     const res = await forEachTableRowsBatch('tips', 'fid, wallet_address', 3000, processTipsBatch);

app/api/metadata/route.tsx

@@ -0,0 +1,25 @@
+import { NextRequest, NextResponse } from 'next/server';
+import fetchMetadata from '@/lib/fetchMetadata';
+import { SupabasePost } from '@/types/SupabasePost';
+
+export async function GET(req: NextRequest) {
+  const songLink = req.nextUrl.searchParams.get('songLink');
+  if (!songLink) {
+    return NextResponse.json({ error: 'songLink is required' }, { status: 400 });
+  }
+
+  try {
+    const metadata = await fetchMetadata(songLink, { id: 1 } as SupabasePost);
+    const external_url = `https://test-sonata.vercel.app/song/${songLink}`;
+    const response = {
+      external_url,
+      name: metadata.trackName,
+      image: metadata.artworkUrl,
+      description: `Listen to ${metadata.trackName} ${metadata.artistName && `by ${metadata.artistName} `}on Sonata - ${external_url}`,
+    };
+    return NextResponse.json(response, { status: 200 });
+  } catch (error) {
+    console.error('Error fetching song metadata:', error);
+    return NextResponse.json({ error: 'Failed to fetch song metadata' }, { status: 500 });
+  }
+}

app/api/neynar/getChannelDetails/route.ts

@@ -1,8 +1,8 @@
-import { NextRequest } from "next/server";
+import { NextRequest } from 'next/server';
 
 const options: any = {
   method: 'GET',
-  headers: { accept: 'application/json', api_key: process.env.NEYNAR_API_KEY }
+  headers: { accept: 'application/json', api_key: process.env.NEYNAR_API_KEY },
 };
 
 export async function GET(req: NextRequest) {
@@ -13,7 +13,10 @@ export async function GET(req: NextRequest) {
 
     const queryParams = new URLSearchParams({ id: channelId, type: 'id' });
 
-    const response = await fetch('https://api.neynar.com/v2/farcaster/channel?' + queryParams.toString(), options);
+    const response = await fetch(
+      'https://api.neynar.com/v2/farcaster/channel?' + queryParams.toString(),
+      options,
+    );
 
     if (!response.ok) throw Error(response.statusText);
 
@@ -26,4 +29,4 @@ export async function GET(req: NextRequest) {
   }
 }
 
-export const revalidate = 600;
+export const revalidate = 600;

app/api/neynar/getUser/route.ts

@@ -15,7 +15,7 @@ export async function GET(req: NextRequest): Promise<Response> {
   }
 
   try {
-    const users = await getBulkUsersByFid(fids)
+    const users = await getBulkUsersByFid(fids);
     return Response.json({ users });
   } catch (error) {
     console.error(error);

app/api/postMusicEmbed/route.ts

@@ -7,8 +7,8 @@ const getResponse = async (req: NextRequest) => {
   const body = await req.json();
   const { signer_uuid, url, channel_id } = body;
 
-  if (!(signer_uuid && url)) return Response
-    .json({ message: 'signer_uuid & url required' }, { status: 400 });
+  if (!(signer_uuid && url))
+    return Response.json({ message: 'signer_uuid & url required' }, { status: 400 });
 
   const data = await postMusicEmbed(signer_uuid, url, channel_id);
 
@@ -30,18 +30,18 @@ const getResponse = async (req: NextRequest) => {
   };
   const { success } = await upsertCast(cast);
 
-  if (!success) return Response.json(
-    { message: 'successfuly casted', data },
-    { status: 200 }
-  );
+  if (!success) return Response.json({ message: 'successfuly casted', data }, { status: 200 });
   sendBotCast(cast);
 
-  return Response.json({
-    message: 'successfuly casted and indexed',
-    link: `/cast/${cast.author.username}/${cast.hash.substring(0, 8)}`
-  }, { status: 307 });
+  return Response.json(
+    {
+      message: 'successfuly casted and indexed',
+      link: `/cast/${cast.author.username}/${cast.hash.substring(0, 8)}`,
+    },
+    { status: 307 },
+  );
 };
 
 export async function POST(req: NextRequest) {
   return getResponse(req);
-}
+}