aqbanking/backendsupport/provider.c

/***************************************************************************
 begin       : Mon Mar 01 2004
 copyright   : (C) 2018 by Martin Preuss
 email       : martin@libchipcard.de

 ***************************************************************************
 * This file is part of the project "AqBanking".                           *
 * Please see toplevel file COPYING of that project for license details.   *
 ***************************************************************************/

#ifdef HAVE_CONFIG_H
# include <config.h>
#endif

#include "aqbanking/backendsupport/provider_p.h"
#include "aqbanking/backendsupport/provider_be.h"
#include "aqbanking/banking_l.h"

#include <gwenhywfar/debug.h>
#include <gwenhywfar/misc.h>
#include <gwenhywfar/text.h>

#include <assert.h>
#include <ctype.h>


GWEN_INHERIT_FUNCTIONS(AB_PROVIDER)
GWEN_LIST_FUNCTIONS(AB_PROVIDER, AB_Provider)
GWEN_LIST2_FUNCTIONS(AB_PROVIDER, AB_Provider)

GWEN_INHERIT(GWEN_PLUGIN, AB_PLUGIN_PROVIDER)


AB_PROVIDER *AB_Provider_new(AB_BANKING *ab, const char *name)
{
  AB_PROVIDER *pro;
  GWEN_BUFFER *nbuf;

  assert(ab);
  assert(name);

  nbuf=GWEN_Buffer_new(0, 256, 0, 1);
  if (GWEN_Text_EscapeToBufferTolerant(name, nbuf)) {
    DBG_ERROR(AQBANKING_LOGDOMAIN,
              "Bad backend name, aborting.");
    GWEN_Buffer_free(nbuf);
    abort();
  }
  else {
    char *s;

    s=GWEN_Buffer_GetStart(nbuf);
    while (*s) {
      *s=tolower(*s);
      s++;
    }
  }

  GWEN_NEW_OBJECT(AB_PROVIDER, pro);
  pro->usage=1;
  GWEN_INHERIT_INIT(AB_PROVIDER, pro);
  GWEN_LIST_INIT(AB_PROVIDER, pro);

  pro->banking=ab;
  pro->name=strdup(name);
  pro->escName=strdup(GWEN_Buffer_GetStart(nbuf));
  GWEN_Buffer_free(nbuf);

  return pro;
}


void AB_Provider_free(AB_PROVIDER *pro)
{
  if (pro) {
    assert(pro->usage);
    if (--(pro->usage)==0) {
      DBG_VERBOUS(AQBANKING_LOGDOMAIN, "Destroying AB_PROVIDER (%s)",
                  pro->name);
      GWEN_INHERIT_FINI(AB_PROVIDER, pro);
      GWEN_Plugin_free(pro->plugin);
      free(pro->name);
      free(pro->escName);
      GWEN_LIST_FINI(AB_PROVIDER, pro);
      GWEN_FREE_OBJECT(pro);
    }
  }
}


void AB_Provider_AddFlags(AB_PROVIDER *pro, uint32_t fl)
{
  assert(pro);
  pro->flags|=fl;
}


void AB_Provider_SetPlugin(AB_PROVIDER *pro, GWEN_PLUGIN *pl)
{
  assert(pro);
  pro->plugin=pl;
}


int AB_Provider_Init(AB_PROVIDER *pro, GWEN_DB_NODE *db)
{
  assert(pro);
  if (pro->initCounter==0) {
    if (pro->initFn) {
      int rv;

      rv=pro->initFn(pro, db);
      if (!rv) {
        pro->initCounter++;
      }
      return rv;
    }
    else {
      DBG_ERROR(AQBANKING_LOGDOMAIN, "No init function set");
      return GWEN_ERROR_NOT_IMPLEMENTED;
    }
  }
  else {
    pro->initCounter++;
    DBG_INFO(AQBANKING_LOGDOMAIN, "Backend already initialised, increasing counter to %d", pro->initCounter);
    return 0;
  }
}


int AB_Provider_Fini(AB_PROVIDER *pro, GWEN_DB_NODE *db)
{
  assert(pro);

  if (pro->initCounter==1) {
    if (pro->finiFn) {
      int rv;

      rv=pro->finiFn(pro, db);
      pro->initCounter=0;
      if (rv<0) {
        DBG_INFO(AQBANKING_LOGDOMAIN, "here (%d)", rv);
        return rv;
      }
      return rv;
    }
    else {
      DBG_ERROR(AQBANKING_LOGDOMAIN, "No fini function set");
      pro->initCounter=0;
      return GWEN_ERROR_NOT_IMPLEMENTED;
    }
  }
  else if (pro->initCounter>0) {
    pro->initCounter--;
    DBG_INFO(AQBANKING_LOGDOMAIN, "Backend still initialised, decreasing counter to %d", pro->initCounter);
    return 0;
  }
  else {
    DBG_ERROR(AQBANKING_LOGDOMAIN, "Provider is not initialized");
    return GWEN_ERROR_INVALID;
  }
}


const char *AB_Provider_GetName(const AB_PROVIDER *pro)
{
  assert(pro);
  return pro->name;
}


const char *AB_Provider_GetEscapedName(const AB_PROVIDER *pro)
{
  assert(pro);
  return pro->escName;
}


AB_BANKING *AB_Provider_GetBanking(const AB_PROVIDER *pro)
{
  assert(pro);
  return pro->banking;
}


void AB_Provider_SetInitFn(AB_PROVIDER *pro, AB_PROVIDER_INIT_FN f)
{
  assert(pro);
  pro->initFn=f;
}


void AB_Provider_SetFiniFn(AB_PROVIDER *pro, AB_PROVIDER_FINI_FN f)
{
  assert(pro);
  pro->finiFn=f;
}


void AB_Provider_SetGetNewUserDialogFn(AB_PROVIDER *pro, AB_PROVIDER_GET_NEWUSER_DIALOG_FN f)
{
  assert(pro);
  pro->getNewUserDialogFn=f;
}


void AB_Provider_SetGetEditUserDialogFn(AB_PROVIDER *pro, AB_PROVIDER_GET_EDITUSER_DIALOG_FN f)
{
  assert(pro);
  pro->getEditUserDialogFn=f;
}


void AB_Provider_SetGetNewAccountDialogFn(AB_PROVIDER *pro, AB_PROVIDER_GET_NEWACCOUNT_DIALOG_FN f)
{
  assert(pro);
  pro->getNewAccountDialogFn=f;
}


void AB_Provider_SetGetEditAccountDialogFn(AB_PROVIDER *pro, AB_PROVIDER_GET_EDITACCOUNT_DIALOG_FN f)
{
  assert(pro);
  pro->getEditAccountDialogFn=f;
}


void AB_Provider_SetGetUserTypeDialogFn(AB_PROVIDER *pro, AB_PROVIDER_GET_USERTYPE_DIALOG_FN f)
{
  assert(pro);
  pro->getUserTypeDialogFn=f;
}


void AB_Provider_SetSendCommandsFn(AB_PROVIDER *pro, AB_PROVIDER_SENDCOMMANDS_FN f)
{
  assert(pro);
  pro->sendCommandsFn=f;
}


void AB_Provider_SetCreateAccountObjectsFn(AB_PROVIDER *pro, AB_PROVIDER_CREATEACCOUNTOBJECT_FN f)
{
  assert(pro);
  pro->createAccountObjectFn=f;
}


void AB_Provider_SetCreateUserObjectsFn(AB_PROVIDER *pro, AB_PROVIDER_CREATEUSEROBJECT_FN f)
{
  assert(pro);
  pro->createUserObjectFn=f;
}


void AB_Provider_SetUpdateAccountSpecFn(AB_PROVIDER *pro, AB_PROVIDER_UPDATEACCOUNTSPEC_FN f)
{
  assert(pro);
  pro->updateAccountSpecFn=f;
}


void AB_Provider_SetControlFn(AB_PROVIDER *pro, AB_PROVIDER_CONTROL_FN f)
{
  assert(pro);
  pro->controlFn=f;
}


AB_ACCOUNT *AB_Provider_CreateAccountObject(AB_PROVIDER *pro)
{
  assert(pro);
  if (pro->createAccountObjectFn)
    return pro->createAccountObjectFn(pro);
  else
    return NULL;
}


AB_USER *AB_Provider_CreateUserObject(AB_PROVIDER *pro)
{
  assert(pro);
  if (pro->createUserObjectFn)
    return pro->createUserObjectFn(pro);
  else
    return NULL;
}


int AB_Provider_UpdateAccountSpec(AB_PROVIDER *pro, AB_ACCOUNT_SPEC *as, int doLock)
{
  assert(pro);
  if (pro->updateAccountSpecFn)
    return pro->updateAccountSpecFn(pro, as, doLock);
  else
    return GWEN_ERROR_NOT_IMPLEMENTED;
}


int AB_Provider_Control(AB_PROVIDER *pro, int argc, char **argv)
{
  assert(pro);
  if (pro->controlFn)
    return pro->controlFn(pro, argc, argv);
  else
    return GWEN_ERROR_NOT_IMPLEMENTED;
}


GWEN_DIALOG *AB_Provider_GetNewUserDialog(AB_PROVIDER *pro, int i)
{
  assert(pro);
  if (pro->getNewUserDialogFn)
    return pro->getNewUserDialogFn(pro, i);
  else
    return NULL;
}


GWEN_DIALOG *AB_Provider_GetEditUserDialog(AB_PROVIDER *pro, AB_USER *u)
{
  assert(pro);
  if (pro->getEditUserDialogFn) {
    DBG_INFO(AQBANKING_LOGDOMAIN, "calling pro->getEditUserDialogFn");
    return pro->getEditUserDialogFn(pro, u);
  }
  else {
    DBG_INFO(AQBANKING_LOGDOMAIN, "No getEditUserDialogFn set");
    return NULL;
  }
}


GWEN_DIALOG *AB_Provider_GetNewAccountDialog(AB_PROVIDER *pro)
{
  assert(pro);
  if (pro->getNewAccountDialogFn)
    return pro->getNewAccountDialogFn(pro);
  else
    return NULL;
}


GWEN_DIALOG *AB_Provider_GetEditAccountDialog(AB_PROVIDER *pro, AB_ACCOUNT *a)
{
  assert(pro);
  if (pro->getEditAccountDialogFn)
    return pro->getEditAccountDialogFn(pro, a);
  else
    return NULL;
}


GWEN_DIALOG *AB_Provider_GetUserTypeDialog(AB_PROVIDER *pro)
{
  assert(pro);
  if (pro->getUserTypeDialogFn)
    return pro->getUserTypeDialogFn(pro);
  else
    return NULL;
}


int AB_Provider_SendCommands(AB_PROVIDER *pro, AB_PROVIDERQUEUE *pq, AB_IMEXPORTER_CONTEXT *ctx)
{
  assert(pro);
  if (pro->sendCommandsFn)
    return pro->sendCommandsFn(pro, pq, ctx);
  else
    return GWEN_ERROR_NOT_SUPPORTED;
}


int AB_Provider_IsInit(const AB_PROVIDER *pro)
{
  assert(pro);
  return (pro->initCounter>0);
}


uint32_t AB_Provider_GetFlags(const AB_PROVIDER *pro)
{
  assert(pro);
  return pro->flags;
}


int AB_Provider_GetUserDataDir(const AB_PROVIDER *pro, GWEN_BUFFER *buf)
{
  assert(pro);
  assert(buf);
  assert(pro->banking);
  assert(pro->escName);

  return AB_Banking_GetProviderUserDataDir(pro->banking,
                                           pro->escName,
                                           buf);
}


GWEN_PLUGIN *AB_Plugin_Provider_new(GWEN_PLUGIN_MANAGER *pm,
                                    const char *name,
                                    const char *fileName)
{
  GWEN_PLUGIN *pl;
  AB_PLUGIN_PROVIDER *xpl;

  pl=GWEN_Plugin_new(pm, name, fileName);
  GWEN_NEW_OBJECT(AB_PLUGIN_PROVIDER, xpl);
  GWEN_INHERIT_SETDATA(GWEN_PLUGIN, AB_PLUGIN_PROVIDER, pl, xpl,
                       AB_Plugin_Provider_FreeData);

  return pl;

}


void GWENHYWFAR_CB AB_Plugin_Provider_FreeData(void *bp, void *p)
{
  AB_PLUGIN_PROVIDER *xpl;

  xpl=(AB_PLUGIN_PROVIDER *)p;
  GWEN_FREE_OBJECT(xpl);
}


AB_PROVIDER *AB_Plugin_Provider_Factory(GWEN_PLUGIN *pl, AB_BANKING *ab)
{
  AB_PLUGIN_PROVIDER *xpl;

  assert(pl);
  xpl=GWEN_INHERIT_GETDATA(GWEN_PLUGIN, AB_PLUGIN_PROVIDER, pl);
  assert(xpl);

  assert(xpl->pluginFactoryFn);
  return xpl->pluginFactoryFn(pl, ab);
}


void AB_Plugin_Provider_SetFactoryFn(GWEN_PLUGIN *pl, AB_PLUGIN_PROVIDER_FACTORY_FN fn)
{
  AB_PLUGIN_PROVIDER *xpl;

  assert(pl);
  xpl=GWEN_INHERIT_GETDATA(GWEN_PLUGIN, AB_PLUGIN_PROVIDER, pl);
  assert(xpl);

  xpl->pluginFactoryFn=fn;
}


#include "provider_account.c"
#include "provider_accspec.c"
#include "provider_user.c"
#include "provider_queues.c"