socket tools

src/app/pages/ownersjob/ownersjob.page.ts

@@ -3,6 +3,7 @@ import {LoadingController, NavController} from "@ionic/angular";
 import {Router} from "@angular/router";
 import {SessionDataProviderService} from "../../store/session-data-provider.service";
 import {WrenchService} from "../../services/wrench.service";
+import {SocketToolsService} from "../../services/socket-tools.service";
 
 @Component({
   selector: 'app-ownersjob',
@@ -21,6 +22,7 @@ export class OwnersjobPage implements OnInit {
   constructor(
       private navctr: NavController,
       private router: Router,
+      private  socketToolsService: SocketToolsService,
       public sessionDataProviderService: SessionDataProviderService,
       private wrenchService: WrenchService,
       private loadingCtrl: LoadingController
@@ -32,6 +34,7 @@ export class OwnersjobPage implements OnInit {
     if (this.jobData== undefined){
       this.onBack();
     }
+      this.socketToolsService.joinSocketRoom("full-market-jobs" );
     //debugger;
   }
   onBack() {
@@ -166,6 +169,7 @@ if ( this.job_duration== undefined || this.job_duration < 1){
                 const event = new Event("app-myjob-offers-refresh");
                 // Dispatch the event.
                 dispatchEvent(event);
+                this.socketToolsService.emmitSocketEvent("send_message","market", "full-market-jobs");
                 setTimeout(() => {
                     this.assign_mak_result ='';
                 }, 3000);

src/app/services/socket-tools.service.ts

@@ -42,11 +42,14 @@ export class SocketToolsService {
     this.connectionSubject = new BehaviorSubject<boolean>(false);
 
     this.socket.on('receive_message', () => {
-     debugger;
       const event = new Event("app-taskactivities-refresh");
       dispatchEvent(event);
     });
 
+    this.socket.on('received_refreshmarket_jobs', (data) => {
+      debugger
+    });
+
 
     this.socket.on('connect', () => {
       this.connectionSubject.next(true);