reuser.cc

Go to the documentation of this file.

/*
 SPDX-License-Identifier: GPL-2.0-only
 Author: Dietmar Helmut Leher <helmut.leher.ext@vaillant-group.com>
 SPDX-FileCopyrightText: © 2026 Vaillant GmbH
*/
#include "ReuserUtils.hpp"
 
int main(int argc, char** argv)
{
  fo::DbManager dbManager(&argc, argv);
  ReuserDatabaseHandler databaseHandler(dbManager);
 
  ReuserState state = getState(dbManager);
 
  while (fo_scheduler_next() != nullptr)
  {
    int uploadId = atoi(fo_scheduler_current());
    if (uploadId == 0) continue;
 
    int arsId = writeARS(state, 0, uploadId, 0, dbManager);
    if (arsId <= 0)
    {
      LOG_ERROR("Reuser: failed to write ARS start record for upload %d, skipping.",
                uploadId);
      continue;
    }
 
    if (!processUploadId(state, uploadId, databaseHandler))
    {
      writeARS(state, arsId, uploadId, 0, dbManager);
      bail(2);
    }
 
    fo_scheduler_heart(0);
    writeARS(state, arsId, uploadId, 1, dbManager);
  }
 
  fo_scheduler_heart(0);
  fo_scheduler_disconnect(0);
  return 0;
}