+
+ {
+ session.status === "authenticated" && (wallet ? : )
+ }
+ {/* {wallet ? : } */}
{session.data?.user && }
{!session.data?.user &&}
diff --git a/app/components/StreamView.tsx b/app/components/StreamView.tsx
index 2bc7b46..e510c57 100644
--- a/app/components/StreamView.tsx
+++ b/app/components/StreamView.tsx
@@ -10,10 +10,14 @@ import { Appbar } from './Appbar'
import LiteYouTubeEmbed from 'react-lite-youtube-embed'
import 'react-lite-youtube-embed/dist/LiteYouTubeEmbed.css'
import { YT_REGEX } from '../lib/utils'
+//@ts-ignore
import YouTubePlayer from 'youtube-player'
import { useSession } from "next-auth/react"
import type { Session } from "next-auth"
import { Dialog, DialogContent, DialogHeader, DialogTitle, DialogDescription, DialogFooter } from "@/components/ui/dialog"
+import { useConnection, useWallet } from '@solana/wallet-adapter-react'
+import { PublicKey, SystemProgram, Transaction } from '@solana/web3.js';
+import {DEFAULT_LAMPORT, PUBLIC_KEY_ADDRESS} from "@/app/lib/constants"
interface Video {
id: string
@@ -58,6 +62,10 @@ export default function StreamView({
const [isCreator, setIsCreator] = useState(false)
const [isEmptyQueueDialogOpen, setIsEmptyQueueDialogOpen] = useState(false)
+ const { publicKey, sendTransaction } = useWallet();
+ const { connection } = useConnection();
+
+
async function refreshStreams() {
try {
const res = await fetch(`/api/streams/?creatorId=${creatorId}`, {
@@ -173,23 +181,72 @@ export default function StreamView({
})
}
- const playNext = async () => {
- if (queue.length > 0) {
- try {
- setPlayNextLoader(true)
- const data = await fetch('/api/streams/next', {
- method: "GET",
+ const sendSOL = async() => {
+ if (!publicKey){
+ toast.error("Please connect the Wallet to continue");
+ return;
+ }
+
+ const lamports = DEFAULT_LAMPORT;
+
+ const {
+ context: { slot: minContextSlot },
+ value: { blockhash, lastValidBlockHeight }
+ } = await connection.getLatestBlockhashAndContext();
+
+ const transaction = new Transaction().add(
+ SystemProgram.transfer({
+ fromPubkey: publicKey,
+ toPubkey: new PublicKey(PUBLIC_KEY_ADDRESS),
+ lamports,
+ })
+ );
+
+ const signature = await sendTransaction(transaction, connection, { minContextSlot });
+ await connection.confirmTransaction({ blockhash, lastValidBlockHeight, signature });
+ return signature;
+ }
+
+ const playNext = async (streamId?:string) => {
+
+ if (queue.length > 0) {
+ try {
+ setPlayNextLoader(true)
+ let data;
+
+ if(streamId){
+
+ const txnSig = await sendSOL();
+
+ if(!txnSig){
+ toast.error("Can't get the Transaction details!!");
+ return;
+ }
+
+ data = await fetch('/api/streams/next', {
+ method: "POST",
+ body:JSON.stringify({
+ streamId,
+ txnSig,
+ })
})
- const json = await data.json()
- setCurrentVideo(json.stream)
- setQueue(q => q.filter(x => x.id !== json.stream?.id))
- } catch(e) {
- console.error("Error playing next song:", e)
- } finally {
- setPlayNextLoader(false)
}
+ else{
+ data = await fetch('/api/streams/next', {
+ method: "GET",
+ })
+ }
+
+ const json = await data.json();
+ setCurrentVideo(json.stream)
+ setQueue(q => q.filter(x => x.id !== json.stream?.id))
+ } catch(e) {
+ console.error("Error playing next song:", e)
+ }finally {
+ setPlayNextLoader(false)
}
}
+ }
const handleShare = () => {
const shareableLink = `${window.location.origin}/creator/${creatorId}`
@@ -296,7 +353,16 @@ export default function StreamView({
)}
-