added chunkstream method to chaatAi

Author: ehsan6sha

example/src/App.tsx

@@ -1307,6 +1307,61 @@ const App = () => {
  />
  </View>
 
+ <View style={styles.section}>
+ <Button
+ title={inprogress ? 'Getting...' : 'Test Stream Chunks'}
+ onPress={async () => {
+ try {
+ if (initComplete) {
+ // Step 1: Check connection to Blox
+ const isConnected = await fula.checkConnection();
+ console.log('Connection check:', isConnected);
+
+ if (isConnected) {
+ console.log('Initialization is completed. Starting ChatWithAI...');
+
+ // Step 2: Start Chat with AI
+ try {
+ const streamID = await fxAi.chatWithAI('deepseek-chart', 'Hello AI!');
+ console.log('ChatWithAI started, Stream ID:', streamID);
+
+ // Step 3: Use streamChunks to receive responses in real-time
+ let fullResponse = '';
+ const cleanup = fxAi.streamChunks(streamID, {
+ onChunk: (chunk) => {
+ console.log('Received chunk:', chunk);
+ fullResponse += chunk;
+ },
+ onComplete: () => {
+ console.log('Stream completed. Full response:', fullResponse);
+ },
+ onError: (error) => {
+ console.error('Stream error:', error);
+ },
+ });
+
+ // Optional: Clean up after some time (e.g., if you want to stop receiving chunks)
+ setTimeout(() => {
+ cleanup();
+ console.log('Cleaned up stream listeners');
+ }, 30000); // Cleanup after 30 seconds
+
+ } catch (startError) {
+ console.error('Error starting ChatWithAI:', startError);
+ }
+ } else {
+ console.log('Connection to Blox failed. Please check your connection.');
+ }
+ } else {
+ console.log('Wait for initialization to complete.');
+ }
+ } catch (e) {
+ console.error('Unexpected error:', e);
+ }
+ }}
+ color={inprogress ? 'green' : 'blue'}
+ />
+ </View>
 
  </ScrollView>
  );

package-lock.json

@@ -1,6 +1,6 @@
 {
  "name": "@functionland/react-native-fula",
- "version": "1.55.1",
+ "version": "1.55.2",
  "description": "This package is a bridge to use the Fula libp2p protocols in the react-native which is using wnfs",
  "type": "module",
  "main": "lib/commonjs/index",

package.json

@@ -108,4 +108,75 @@ import { DeviceEventEmitter } from 'react-native';
  }
  });
  });
+ };
+
+ export interface StreamCallbacks {
+ onChunk?: (chunk: string) => void;
+ onComplete?: () => void;
+ onError?: (error: Error) => void;
+ }
+
+ export const streamChunks = (streamID: string, callbacks: StreamCallbacks): () => void => {
+ let active = true;
+
+ const cleanup = () => {
+ active = false;
+ DeviceEventEmitter.removeAllListeners('onChunkReceived');
+ DeviceEventEmitter.removeAllListeners('onStreamingCompleted');
+ DeviceEventEmitter.removeAllListeners('onStreamError');
+ };
+
+ const chunkHandler = (chunk: string) => {
+ if (active && callbacks.onChunk) {
+ callbacks.onChunk(chunk);
+ }
+ };
+
+ const completionHandler = () => {
+ if (active) {
+ cleanup();
+ if (callbacks.onComplete) {
+ callbacks.onComplete();
+ }
+ }
+ };
+
+ const errorHandler = (error: string) => {
+ if (active) {
+ cleanup();
+ if (error.includes('EOF')) {
+ // Treat EOF as successful completion
+ console.log('Stream completed with EOF');
+ if (callbacks.onComplete) {
+ callbacks.onComplete();
+ }
+ } else {
+ console.error('Stream error:', error);
+ if (callbacks.onError) {
+ callbacks.onError(new Error(error || 'Unknown stream error'));
+ }
+ }
+ }
+ };
+
+ DeviceEventEmitter.addListener('onChunkReceived', chunkHandler);
+ DeviceEventEmitter.addListener('onStreamingCompleted', completionHandler);
+ DeviceEventEmitter.addListener('onStreamError', errorHandler);
+
+ Fula.streamChunks(streamID)
+ .catch(error => {
+ if (active) {
+ cleanup();
+ if (error.message.includes('EOF')) {
+ if (callbacks.onComplete) {
+ callbacks.onComplete();
+ }
+ } else if (callbacks.onError) {
+ callbacks.onError(error);
+ }
+ }
+ });
+
+ // Return a cleanup function that the caller can use to stop listening
+ return cleanup;
  };