Push Changes

[MUR-88]

i want to push the data from watermelondb to sync the data with this code

---

front-end code

import { useEffect, useState } from "react"; import NetInfo from "@react-native-community/netinfo"; import { synchronize, hasUnsyncedChanges } from "@nozbe/watermelondb/sync"; import { database } from "../assets/Model/db"; import API from "../function/API"; import dayjs from "dayjs"; import { Q } from "@nozbe/watermelondb"; import useLoadingStore from "./useLoadingStore";

export const useAllSync = ({ isGetData }) => { // const . cari connected atau tidak // setelah itu useEffect untuk ambil data dari API jika connected, jika tidak ambil data dari WatermelonDB const [connected, setConnected] = useState(undefined);

const { setIsLoading } = useLoadingStore();

async function fetching() { const isFirstSync = response; const response = await synchronize({ onWillApplyRemoteChanges: () => { setIsLoading(false); }, onDidPullChanges: async () => { setIsLoading(false); }, database, pullChanges: async ({ schemaVersion, lastPulledAt, migration }) => { setIsLoading(true); // console.log("last pull All Sync", lastPulledAt); const urlParams = last_pulled_at=${ lastPulledAt ? lastPulledAt : "" }&schema_version=${schemaVersion}&migration=${encodeURIComponent( JSON.stringify(migration) )}; const response = await API.get(allSync?${urlParams}); // console.log(JSON.stringify(response, null, 2));

    // Check if the request was successful
    if (response.status_code !== 200) {
      throw new Error(`Request failed with status ${response.status}`);
    }
    const timestamp = dayjs().unix() * 1000;

    if (isFirstSync) {
      const syncJson = JSON.stringify(response.data);
      return { syncJson };
    } else {
      return { changes: response.data, timestamp: timestamp };
    }
  },

  pushChanges: async ({ changes, lastPulledAt }) => {
    const masterLogCreated = changes.master_log_activities.created.filter(
      (item) => item.isSync === false
    );
    const masterLogUpdated = changes.master_log_activities.updated.filter(
      (item) => item.isSync === false
    );

    const masterMachineCreated = changes.master_machine.created.filter(
      (item) => item.isSync === false
    );
    // const masterMachineUpdated = changes.master_machine.updated.filter(
    //   (item) => item.isSync === false
    // );

    // console.log("Created", JSON.stringify(masterLogCreated, null, 2));
    // console.log("Updated", JSON.stringify(masterLogUpdated, null, 2));

    try {
      const pushDataResponse = await API.post("push/data", {
        master_log_activities: {
          created: masterLogCreated,
          updated: masterLogUpdated,
        },
        master_machine: {
          created: masterMachineCreated,
          // updated: masterMachineUpdated,
        },
        last_pulled_at: lastPulledAt,
      });

      // console.log(JSON.stringify(pushDataResponse, null, 2));

      const syncAndUpdate = async (items, updateFunction) => {
        await database.write(async () => {
          console.log("Test", JSON.stringify(items, null, 2));
          const allItems = await database
            .get(items)
            .query(Q.where("isSync", false))
            .fetch();
          for (let i = 0; i < allItems.length; i++) {
            await allItems[i].update(updateFunction);
          }
        });
      };

      await syncAndUpdate("master_log_activities", (masterLog) => {
        masterLog.isSync = true;
      });
      await syncAndUpdate("master_machine", (masterMachine) => {
        masterMachine.isSync = true;
      });

      console.log("pushDataResponse", pushDataResponse);
      return Promise.resolve();
    } catch (pushDataError) {
      console.error(pushDataError);
      return Promise.reject(pushDataError);
      throw new Error(pushDataError.message);
    }
  },
  migrationsEnabledAtVersion: 1,
  unsafeTurbo: isFirstSync,
});

const unsyncedChangesResponse = await hasUnsyncedChanges({ database });
console.log("unsyncedChangesResponse", unsyncedChangesResponse);

}

useEffect(() => { const checkInternetConnection = async () => { try { const netInfoState = await NetInfo.fetch(); setConnected(netInfoState.isConnected); } catch (netInfoError) { console.error("Error checking internet connection", netInfoError); } }; checkInternetConnection(); }, []);

return { connected, fetching }; };

---

back-end

function push_data(Request $request) { $validate = Validator::make($request->all(), [ 'master_log_activities' => 'array', 'master_log_activities.created' => 'array', 'master_log_activities.updated' => 'array', 'master_machine' => 'array', 'master_machine.created' => 'array', 'master_machine.updated' => 'array', 'master_log_activities.created..master_company_id' => ['required', Rule::exists('master_companies', 'id')], 'master_log_activities.created..master_sector_id' => ['required', Rule::exists('master_sectors', 'id')], 'master_log_activities.created..master_machine_id' => ['required', Rule::exists('master_machines', 'id')], 'master_log_activities.created..master_machine_types_id' => ['required', Rule::exists('master_machine_types', 'id')], 'master_log_activities.created..master_main_activity_id' => ['required', Rule::exists('master_main_activities', 'id')], 'master_log_activities.created..compartement_id' => 'required', 'master_log_activities.created..current_hour_meter' => 'required', 'master_log_activities.created..last_hour_meter' => 'required', 'master_log_activities.created..keterangan' => 'nullable', 'master_log_activities.created..created_at' => 'required|numeric', 'master_log_activities.created.*.updated_at' => 'required|numeric',

  'master_log_activities.updated.*.master_company_id' => ['required', Rule::exists('master_companies', 'id')],
  'master_log_activities.updated.*.master_sector_id' => ['required', Rule::exists('master_sectors', 'id')],
  'master_log_activities.updated.*.master_machine_id' => ['required', Rule::exists('master_machines', 'id')],
  'master_log_activities.updated.*.master_machine_types_id' => ['required', Rule::exists('master_machine_types', 'id')],
  'master_log_activities.updated.*.master_main_activity_id' => ['required', Rule::exists('master_main_activities', 'id')],
  'master_log_activities.updated.*.compartement_id' => 'required',
  'master_log_activities.updated.*.current_hour_meter' => 'required',
  'master_log_activities.updated.*.last_hour_meter' => 'required',
  'master_log_activities.updated.*.keterangan' => 'nullable',
  'master_log_activities.updated.*.created_at' => 'required|numeric',
  'master_log_activities.updated.*.updated_at' => 'required|numeric',

if ($validate->fails()) { return response()->json([ 'status_code' => 422, 'status' => 0, 'message' => $validate->errors()->first(), ], 422); }

$master_log_activities_created = $request->master_log_activities['created'];
$master_log_activities_updated = $request->master_log_activities['updated'];

$master_machine_created = $request->master_machine['created'];
// $master_machine_updated = $request->master_machine['updated'];

Log::info($request->all());
try {
  DB::beginTransaction();

  foreach (collect($master_log_activities_created) as $item) {

    $userId = Auth::id();
    MasterLogActivity::create([
      'user_id' => $userId,
      'master_company_id' => $item['master_company_id'],
      'master_sector_id' => $item['master_sector_id'],
      'master_machine_id' => $item['master_machine_id'],
      'master_machine_type_id' => $item['master_machine_types_id'],
      'master_main_activity_id' => $item['master_main_activity_id'],
      'compartement_id' => $item['compartement_id'],
      'current_hour_meter' => $item['current_hour_meter'],
      'last_hour_meter' => $item['last_hour_meter'],
      'keterangan' => $item['keterangan'],
      'created_at' => Carbon::parse($item['created_at']),
      'isSync' => true,
      'brand' => 'komatsu',
      'isConnected' => true,
      'updated_at' => Carbon::parse($item['updated_at']),
    ]);
  }

  foreach (collect($master_log_activities_updated) as $item) {
    $userId = Auth::id();
    $masterLogActivity = MasterLogActivity::find($item->id);
    if ($masterLogActivity) {
      $masterLogActivity->update([
        'user_id' => $userId,
        'master_company_id' => $item['master_company_id'],
        'master_sector_id' => $item['master_sector_id'],
        // 'master_estate_id' => $item['master_estate_id'],
        'master_machine_id' => $item['master_machine_id'],
        'master_machine_type_id' => $item['master_machine_types_id'],
        'master_main_activity_id' => $item['master_main_activity_id'],
        'compartement_id' => $item['compartement_id'],
        'current_hour_meter' => $item['current_hour_meter'],
        'last_hour_meter' => $item['last_hour_meter'],
        'keterangan' => $item['keterangan'],
        'created_at' => Carbon::parse($item['created_at']),
        'isSync' => true,
        'brand' => 'komatsu',
        'isConnected' => true,
        'updated_at' => Carbon::parse($item['updated_at']),
      ]);
    }
  }

DB::commit(); } catch (\Exception $e) { // Log the exception for debugging Log::error($e); DB::rollBack();

  return response()->json([
    'status_code' => 500,
    'status' => 0,
    'message' => $e->getMessage(),
  ], 500);
}

return response()->json([
  'status_code' => 200,
  'status' => 1,
  'message' => 'Berhasil menambah data',
]);

}

this code is check by isSync = false then sync the data, but when the data has updated the data not sync updated

---

![Uploading image.png…]() console.log data { "id": "zvpkGj7ges5VMEvT", "_status": "synced", "_changed": "", "id_master_log_activity": 11, "master_company_id": 20, "master_sector_id": 1, "master_machine_id": 77, "master_machine_types_id": 3, "master_main_activity_id": 19, "compartement_id": "AB701", "current_hour_meter": 20, "last_hour_meter": 7, "keterangan": "2", "isSync": true, "isConnected": false, "created_at": 1710860013000, "date": 1710860013000, "deleted_at": 0, "updated_at": 1711032813000 }

how i can push the data within get pushing by _changed. currently i cannot recieve when the data updated

when isSync = false then sync the data, but when the data has updated the data not sync updated

any idea?