Chat with self for free account getstream.io

Author: maearon

README.md

@@ -74,6 +74,8 @@ npx prisma migrate dev (rails db:migrate)
 rails db:seed (prisma introspect && npx prisma db pull && npx prisma db push)
 cd ..
 rails s -p 3001
+(git checkout 1242dc57c527178d6bffd6980c884ba4478bafd4 -- db/migrate)
+(rails status code symbol: https://gist.github.com/mlanett/a31c340b132ddefa9cca)
 ```
 
 ## Links

app/controllers/api/users_controller.rb

@@ -1,10 +1,11 @@
 class Api::UsersController < Api::ApiController
-  before_action :authenticate!, except: %i[create, update]
+  before_action :authenticate!, except: %i[create, update, index]
   before_action :set_user,       except: %i[index create]
   before_action :correct_user,   only: %i[destroy]
   before_action :admin_user,     only: %i[destroy]
 
   def index
+    # @users = User.all.page(params[:page])
     @users = User.all.page(params[:page])
     @total, users = pager(User.all.order(id: :asc))
   end

app/views/api/users/index.json.jbuilder

@@ -2,10 +2,9 @@ json.users do
   json.array!(@users) do |u|
     json.id u.id
     json.name u.name
-    json.email u.email
-    json.gravatar_id Digest::MD5::hexdigest(u.email.downcase)
-    json.size 50
-    json.admin u.admin
+    json.username u.username
+    json.displayName u.displayName
+    json.avatarUrl u.avatarUrl
   end
 end
 json.total_count @total

client/src/app/(auth)/signup/actions.ts

@@ -65,6 +65,7 @@ export async function signUp(
           passwordHash,
         },
       });
+      // stream upsertUser
       await streamServerClient.upsertUser({
         id: userId,
         username,

client/src/app/(main)/messages/NewChatDialog.tsx

@@ -44,7 +44,7 @@ export default function NewChatDialog({
       client.queryUsers(
         {
           id: { $ne: loggedInUser.id },
-          role: { $ne: "admin" },
+          // role: { $ne: "user" },
           ...(searchInputDebounced
             ? {
                 $or: [
@@ -61,16 +61,20 @@ export default function NewChatDialog({
 
   const mutation = useMutation({
     mutationFn: async () => {
-      const channel = client.channel("messaging", {
-        members: [loggedInUser.id, ...selectedUsers.map((u) => u.id)],
-        name:
-          selectedUsers.length > 1
-            ? loggedInUser.displayName +
-              ", " +
-              selectedUsers.map((u) => u.name).join(", ")
-            : undefined,
+      const channelId = `self-chat-${loggedInUser.id}`;
+      const channel = client.channel("messaging", channelId, {
+        members: [loggedInUser.id],
+        name: loggedInUser.displayName
       });
-      await channel.create();
+      try {
+        const response = await channel.create();
+        console.log('Channel created:', response);
+      } catch (error) {
+        console.error('Error creating channel:', error);
+      }
+      const result = await channel.addMembers([{user_id: "00cffeed-248f-4fc5-92ff-b99ebbad7e8d"}]);
+      // const result1 = await channel.addMembers([{user_id: "0649d146-060c-4c8e-86c1-b975947c49b4"}]);
+      console.log(result.members[0].channel_role) // "channel_member"
       return channel;
     },
     onSuccess: (channel) => {

client/src/app/(main)/messages/useInitializeChatClient.ts

@@ -1,39 +1,84 @@
 import kyInstance from "@/lib/ky";
 import { useEffect, useState } from "react";
-import { StreamChat } from "stream-chat";
+import { StreamChat, UserResponse } from "stream-chat";
 import { useSession } from "../SessionProvider";
+import { index } from "@/components/shared/api/userApi";
 
 export default function useInitializeChatClient() {
   const { user } = useSession();
   const [chatClient, setChatClient] = useState<StreamChat | null>(null);
 
   useEffect(() => {
-    const client = StreamChat.getInstance(process.env.NEXT_PUBLIC_STREAM_KEY!);
-
-    client
-      .connectUser(
-        {
-          id: user.id,
-          username: user.username,
-          name: user.displayName,
-          image: user.avatarUrl,
-        },
-        async () =>
-          kyInstance
-            .get("/api/get-token")
-            // .get("/api/sessions")
-            .json<{ token: string }>()
-            .then((data) => data.token),
-      )
-      .catch((error) => console.error("Failed to connect user", error))
-      .then(() => setChatClient(client));
+    const initializeChatClient = async () => {
+      try {
+        // Khởi tạo client Stream Chat
+        const client = StreamChat.getInstance(process.env.NEXT_PUBLIC_STREAM_KEY!);
 
+        // Upsert người dùng lên Stream Chat
+        
+        try {
+          const usersResponse = await index({ page: 1 });
+          const users = usersResponse.users;
+          const transformedUsers: UserResponse[] = users.map(user => ({
+            id: user.id,
+            username: user.username,
+            name: user.name,
+            image: user.avatarUrl,
+          }));
+          await client.upsertUsers(transformedUsers)
+          // client.partialUpdateUser({...users[0], set: {role: "admin"}})
+          await client.partialUpdateUser({id: "00cffeed-248f-4fc5-92ff-b99ebbad7e8d", set: {role: "admin"}})
+        } catch (error) {
+          console.error("Failed to upsert users", error);
+        }
+
+        
+
+        // const batchSize = 100; // Kích thước của mỗi batch
+        // const upsertUsersInBatches = async (users: any[]) => {
+        //   for (let i = 0; i < users.length; i += batchSize) {
+        //     const batch = users.slice(i, i + batchSize);
+        //     await client.partialUpdateUsers(batch);
+        //   }
+        // };
+
+        // await upsertUsersInBatches(users);
+
+        // Kết nối người dùng với Stream Chat
+        await client.connectUser(
+          {
+            id: user.id,
+            username: user.username,
+            name: user.displayName,
+            image: user.avatarUrl,
+          },
+          async () => {
+            const response = await kyInstance.get("/api/get-token").json<{ token: string }>();
+            return response.token;
+          }
+        );
+
+        
+
+        // Cập nhật state với client đã kết nối
+        setChatClient(client);
+      } catch (error) {
+        console.error("Failed to initialize chat client", error);
+      }
+
+      // Cleanup khi component bị unmount
+      return () => {
+        if (chatClient) {
+          chatClient.disconnectUser().catch((error) => console.error("Failed to disconnect user", error));
+        }
+      };
+    };
+
+    initializeChatClient();
+
+    // Cleanup khi component bị unmount
     return () => {
       setChatClient(null);
-      client
-        .disconnectUser()
-        .catch((error) => console.error("Failed to disconnect user", error))
-        .then(() => console.log("Connection closed"));
     };
   }, [user.id, user.username, user.displayName, user.avatarUrl]);
 

client/src/app/api/auth/callback/google/route.ts

@@ -74,6 +74,7 @@ export async function GET(req: NextRequest) {
           googleId: googleUser.id,
         },
       });
+      // stream upsertUser
       await streamServerClient.upsertUser({
         id: userId,
         username,

client/src/components/shared/api/userApi.tsx

@@ -13,10 +13,13 @@ export interface ListResponse<User> {
 }
 
 export interface User {
-  readonly id: number
+  readonly id: string
   name: string
-  gravatar_id: string
-  size: number
+  username: string
+  displayName: string
+  avatarUrl: string
+  // gravatar_id: string
+  // size: number
 }
 
 export interface CreateParams {
@@ -140,6 +143,7 @@ const userApi = {
 export default userApi;
 export const { create } = userApi;
 export const { update } = userApi;
+export const { index } = userApi;
 
 export interface UserFollow {
   readonly id: number

db/migrate copy/20220402020814_create_active_storage_tables.active_storage.rb

@@ -0,0 +1,57 @@
+# This migration comes from active_storage (originally 20170806125915)
+class CreateActiveStorageTables < ActiveRecord::Migration[5.2]
+  def change
+    # Use Active Record's configured type for primary and foreign keys
+    primary_key_type, foreign_key_type = primary_and_foreign_key_types
+
+    create_table :active_storage_blobs, id: primary_key_type do |t|
+      t.string   :key,          null: false
+      t.string   :filename,     null: false
+      t.string   :content_type
+      t.text     :metadata
+      t.string   :service_name, null: false
+      t.bigint   :byte_size,    null: false
+      t.string   :checksum
+
+      if connection.supports_datetime_with_precision?
+        t.datetime :created_at, precision: 6, null: false
+      else
+        t.datetime :created_at, null: false
+      end
+
+      t.index [ :key ], unique: true
+    end
+
+    create_table :active_storage_attachments, id: primary_key_type do |t|
+      t.string     :name,     null: false
+      t.references :record,   null: false, polymorphic: true, index: false, type: foreign_key_type
+      t.references :blob,     null: false, type: foreign_key_type
+
+      if connection.supports_datetime_with_precision?
+        t.datetime :created_at, precision: 6, null: false
+      else
+        t.datetime :created_at, null: false
+      end
+
+      t.index [ :record_type, :record_id, :name, :blob_id ], name: :index_active_storage_attachments_uniqueness, unique: true
+      t.foreign_key :active_storage_blobs, column: :blob_id
+    end
+
+    create_table :active_storage_variant_records, id: primary_key_type do |t|
+      t.belongs_to :blob, null: false, index: false, type: foreign_key_type
+      t.string :variation_digest, null: false
+
+      t.index [ :blob_id, :variation_digest ], name: :index_active_storage_variant_records_uniqueness, unique: true
+      t.foreign_key :active_storage_blobs, column: :blob_id
+    end
+  end
+
+  private
+    def primary_and_foreign_key_types
+      config = Rails.configuration.generators
+      setting = config.options[config.orm][:primary_key_type]
+      primary_key_type = setting || :primary_key
+      foreign_key_type = setting || :bigint
+      [primary_key_type, foreign_key_type]
+    end
+end

db/migrate copy/20220408200125_create_users.rb

@@ -0,0 +1,15 @@
+class CreateUsers < ActiveRecord::Migration[7.0]
+  def change
+    create_table :users do |t|
+      t.string :name
+      t.string :email
+      t.string "refresh_token"
+      t.datetime "refresh_token_expiration_at"
+
+      t.timestamps
+
+      t.index %i[email], unique: true, name: 'index_admin_users_email_uniqueness'
+      t.index %i[refresh_token], unique: true, name: 'index_admin_users_refresh_token_uniqueness'
+    end
+  end
+end

db/migrate copy/20220408200454_add_index_to_users_email.rb

@@ -0,0 +1,5 @@
+class AddIndexToUsersEmail < ActiveRecord::Migration[7.0]
+  def change
+    add_index :users, :email, unique: true
+  end
+end

db/migrate copy/20220408200615_add_password_digest_to_users.rb

@@ -0,0 +1,5 @@
+class AddPasswordDigestToUsers < ActiveRecord::Migration[7.0]
+  def change
+    add_column :users, :password_digest, :string
+  end
+end

db/migrate copy/20220408205520_add_remember_digest_to_users.rb

@@ -0,0 +1,5 @@
+class AddRememberDigestToUsers < ActiveRecord::Migration[7.0]
+  def change
+    add_column :users, :remember_digest, :string
+  end
+end

db/migrate copy/20220408205851_add_admin_to_users.rb

@@ -0,0 +1,5 @@
+class AddAdminToUsers < ActiveRecord::Migration[7.0]
+  def change
+    add_column :users, :admin, :boolean, default: false
+  end
+end

db/migrate copy/20220408210133_add_activation_to_users.rb

@@ -0,0 +1,7 @@
+class AddActivationToUsers < ActiveRecord::Migration[7.0]
+  def change
+    add_column :users, :activation_digest, :string
+    add_column :users, :activated, :boolean, default: false
+    add_column :users, :activated_at, :datetime
+  end
+end

db/migrate copy/20220408210711_add_reset_to_users.rb

@@ -0,0 +1,6 @@
+class AddResetToUsers < ActiveRecord::Migration[7.0]
+  def change
+    add_column :users, :reset_digest, :string
+    add_column :users, :reset_sent_at, :datetime
+  end
+end

db/migrate copy/20220408210829_create_microposts.rb

@@ -0,0 +1,11 @@
+class CreateMicroposts < ActiveRecord::Migration[7.0]
+  def change
+    create_table :microposts do |t|
+      t.text :content
+      t.references :user, null: false, foreign_key: true
+
+      t.timestamps
+    end
+    add_index :microposts, [:user_id, :created_at]
+  end
+end

db/migrate copy/20220408211102_create_relationships.rb

@@ -0,0 +1,26 @@
+class CreateRelationships < ActiveRecord::Migration[7.0]
+  def change
+    create_table :relationships do |t|
+      t.integer :follower_id
+      t.integer :followed_id
+
+      t.timestamps
+    end
+    add_index :relationships, :follower_id
+    add_index :relationships, :followed_id
+    add_index :relationships, [:follower_id, :followed_id], unique: true
+  end
+end
+
+# class CreateRelationships < ActiveRecord::Migration[7.0]
+#   def change
+#     create_table :relationships do |t|
+#       t.integer :follower_id
+#       t.integer :followed_id
+
+#       t.timestamps
+#     end
+#   end
+# end
+
+# 20190827030205_create_relationships

db/migrate copy/20220925044247_create_products.rb

@@ -0,0 +1,20 @@
+class CreateProducts < ActiveRecord::Migration[6.0]
+  def change
+    create_table :products do |t|
+      t.string :name
+      t.string :jan_code
+      t.string :gender
+      t.string :franchise
+      t.string :producttype
+      t.string :brand
+      t.string :category
+      t.string :sport
+      t.text :description_h5
+      t.text :description_p
+      t.text :specifications
+      t.text :care
+
+      t.timestamps
+    end
+  end
+end