Merge pull request #890 from Udhay-Adithya/add-feature-in-app-terminal

in app terminal logger

Author: animator

lib/apitoolgen/request_consolidator.dart

@@ -50,7 +50,9 @@ class APIDashRequestDescription {
       if (bodyJSON != null) {
         getTyp(input, [i = 0]) {
           String indent = "\t";
-          for (int j = 0; j < i; j++) indent += "\t";
+          for (int j = 0; j < i; j++) {
+            indent += "\t";
+          }
           if (input.runtimeType.toString().toLowerCase().contains('map')) {
             String typd = '{';
             for (final z in input.keys) {

lib/consts.dart

@@ -511,3 +511,6 @@ const kMsgClearHistorySuccess = 'History cleared successfully';
 const kMsgClearHistoryError = 'Error clearing history';
 const kMsgShareError = "Unable to share";
 const kLabelGenerateUI = "Generate UI";
+// Terminal Page
+const kMsgNoLogs = 'No logs yet';
+const kMsgSendToView = 'Send a request to view its details in the console.';

lib/main.dart

@@ -19,7 +19,6 @@ void main() async {
 
   var settingsModel = await getSettingsFromSharedPrefs();
   var onboardingStatus = await getOnboardingStatusFromSharedPrefs();
-  initializeJsRuntime();
   final initStatus = await initApp(
     kIsDesktop,
     settingsModel: settingsModel,

lib/providers/collection_providers.dart

@@ -3,6 +3,7 @@ import 'package:apidash_core/apidash_core.dart';
 import 'package:flutter/material.dart';
 import 'package:flutter_riverpod/flutter_riverpod.dart';
 import 'package:apidash/consts.dart';
+import 'package:apidash/terminal/terminal.dart';
 import 'providers.dart';
 import '../models/models.dart';
 import '../services/services.dart';
@@ -320,7 +321,9 @@ class CollectionStateNotifier
     RequestModel executionRequestModel = requestModel!.copyWith();
 
     if (!requestModel.preRequestScript.isNullOrEmpty()) {
-      executionRequestModel = await handlePreRequestScript(
+      executionRequestModel = await ref
+          .read(jsRuntimeNotifierProvider.notifier)
+          .handlePreRequestScript(
         executionRequestModel,
         originalEnvironmentModel,
         (envModel, updatedValues) {
@@ -347,6 +350,18 @@ class CollectionStateNotifier
           executionRequestModel.httpRequestModel!);
     }
 
+    // Terminal: start network log
+    final terminal = ref.read(terminalStateProvider.notifier);
+    final logId = terminal.startNetwork(
+      apiType: executionRequestModel.apiType,
+      method: substitutedHttpRequestModel.method,
+      url: substitutedHttpRequestModel.url,
+      requestId: requestId,
+      requestHeaders: substitutedHttpRequestModel.enabledHeadersMap,
+      requestBodyPreview: substitutedHttpRequestModel.body,
+      isStreaming: true,
+    );
+
     // Set model to working and streaming
     state = {
       ...state!,
@@ -398,6 +413,17 @@ class CollectionStateNotifier
           ...state!,
           requestId: newRequestModel,
         };
+        // Terminal: append chunk preview
+        if (response != null && response.body.isNotEmpty) {
+          terminal.addNetworkChunk(
+            logId,
+            BodyChunk(
+              ts: DateTime.now(),
+              text: response.body,
+              sizeBytes: response.body.codeUnits.length,
+            ),
+          );
+        }
         unsave();
 
         if (historyModel != null && httpResponseModel != null) {
@@ -425,6 +451,7 @@ class CollectionStateNotifier
       if (!completer.isCompleted) {
         completer.complete((null, null, 'StreamError: $e'));
       }
+      terminal.failNetwork(logId, 'StreamError: $e');
     });
 
     final (response, duration, errorMessage) = await completer.future;
@@ -436,6 +463,7 @@ class CollectionStateNotifier
         isWorking: false,
         isStreaming: false,
       );
+      terminal.failNetwork(logId, errorMessage ?? 'Unknown error');
     } else {
       final statusCode = response.statusCode;
       httpResponseModel = baseHttpResponseModel.fromResponse(
@@ -461,6 +489,14 @@ class CollectionStateNotifier
         isWorking: false,
       );
 
+      terminal.completeNetwork(
+        logId,
+        statusCode: statusCode,
+        responseHeaders: response.headers,
+        responseBodyPreview: httpResponseModel?.body,
+        duration: duration,
+      );
+
       String newHistoryId = getNewUuid();
       historyModel = HistoryRequestModel(
         historyId: newHistoryId,
@@ -487,7 +523,9 @@ class CollectionStateNotifier
           .addHistoryRequest(historyModel!);
 
       if (!requestModel.postRequestScript.isNullOrEmpty()) {
-        newRequestModel = await handlePostResponseScript(
+        newRequestModel = await ref
+            .read(jsRuntimeNotifierProvider.notifier)
+            .handlePostResponseScript(
           newRequestModel,
           originalEnvironmentModel,
           (envModel, updatedValues) {