Package de.pisa.psa.rst.hdl

Class PsaRstApiEvtHdl

java.lang.Object
de.pisa.psa.rst.hdl.PsaRstApiEvtHdl
All Implemented Interfaces:
AutoCloseable
Direct Known Subclasses:
PsaRstApiEvtHdlIn, PsaRstApiEvtHdlOut
public abstract class PsaRstApiEvtHdl extends Object implements AutoCloseable
REST API: event handler
Since:
21.06.2023
Author:
weiland

  • Field Details

    • Max_Records

      protected int Max_Records
      the maximum number of records that are returned

    • Default_User

      protected String Default_User
      default session user

    • Default_External_Language

      protected String Default_External_Language
      the default language for external logins

    • Force_IAM_User

      protected boolean Force_IAM_User
      if IAM is used, the email should belong to an unique user

  • Constructor Details

    • PsaRstApiEvtHdl

      protected PsaRstApiEvtHdl(PsaRstApiEvtHdlDat data)
      Constructor
      Parameters:
      data - event data

  • Method Details

    • handleEvent

      public abstract javax.ws.rs.core.Response handleEvent() throws Exception
      Handle the event
      Returns:
      response
      Throws:
      Exception

    • setActiveEventHandler

      public static void setActiveEventHandler(de.pisa.psc.srv.glb.PscSsn ssn, PsaRstApiEvtHdl handler)
      set the active event handler for a session
      Parameters:
      ssn - session
      handler -

    • getActiveEventHandler

      public static PsaRstApiEvtHdl getActiveEventHandler(de.pisa.psc.srv.glb.PscSsn ssn)
      get the active event handler from a session
      Parameters:
      ssn - session
      Returns:
      handler instance. null if currently no active event handler

    • noEventLogging

      public boolean noEventLogging()
      don't log the event
      Returns:
      if true the event and all logs will be deleted

    • getSsn

      public de.pisa.psc.srv.glb.PscSsn getSsn() throws Exception
      get a session
      Returns:
      session
      Throws:
      Exception

    • getSysSsn

      protected de.pisa.psc.srv.glb.PscSsn getSysSsn() throws Exception
      get a SYSTEM session
      Returns:
      session
      Throws:
      Exception

    • getSsnUsr

      protected String getSsnUsr() throws Exception
      get the user for the database session
      Returns:
      user name
      Throws:
      Exception

    • getIAMUser

      protected String getIAMUser() throws Exception
      get the session user from the IAM token
      Returns:
      user name, null if no IAM token used
      Throws:
      Exception

    • setExternalLanguage

      protected void setExternalLanguage() throws Exception
      set the event language based on the IAM login
      Throws:
      Exception

    • getExternalCommunicationLanguage

      protected String getExternalCommunicationLanguage(de.pisa.psc.srv.glb.PscSsn ssn) throws Exception
      get the communication language from an external login
      Parameters:
      ssn - session
      Returns:
      language identifier
      Throws:
      Exception

    • findEmail

      public Set<String> findEmail(String email)
      find a contact by the email address
      Parameters:
      email - email to search
      Returns:
      set of contact gids that are associated to this email address

    • isIAMUser

      public boolean isIAMUser()
      check if the session user is based on IAM
      Returns:
      true if IAM user

    • fetchIAMContact

      public de.pisa.psc.srv.dto.PscDto fetchIAMContact(String dto_dsc) throws Exception
      fetch a contact based on the IAM email address
      Parameters:
      dto_dsc - descriptor of the contact data object
      Returns:
      contact data abject with one row
      Throws:
      Exception - if the contact was not found or is ambiguous

    • fetchContact

      public de.pisa.psc.srv.dto.PscDto fetchContact(String email, String dto_dsc) throws Exception
      fetch a contact based on an email address
      Parameters:
      email - email address to search
      dto_dsc - descriptor of the contact data object
      Returns:
      contact data abject with one row
      Throws:
      Exception - if the contact was not found or is ambiguous

    • cloneRecords

      protected de.pisa.psc.srv.dto.PscDto cloneRecords(String dto_dsc, Set<String> gid_set, int max) throws Exception
      clone records into a data object
      Parameters:
      dto_dsc - the descriptor of the data object
      gid_set - a set of PSC_GIDs
      max - maximum number of records to clone
      Returns:
      the data object with the records
      Throws:
      Exception

    • getData

      public PsaRstApiEvtHdlDat getData()
      get the event data
      Returns:
      data

    • setJsonIncludeEmpty

      public void setJsonIncludeEmpty(boolean include)
      include empty values in the JSON?
      Parameters:
      include - true to include empty values (default=false)

    • getJsonIncludeEmpty

      public boolean getJsonIncludeEmpty()
      are empty values included in the JSON?
      Returns:
      true if empty values are included

    • toJson

      public String toJson(Object object) throws Exception
      convert an object to JSON
      Parameters:
      object - object to convert
      Returns:
      JSON
      Throws:
      Exception

    • close

      public void close() throws Exception
      Specified by:
      close in interface AutoCloseable
      Throws:
      Exception
      See Also:

    • newDto

      public de.pisa.psc.srv.dto.PscDto newDto(String dsc) throws Exception
      create a new data object
      Parameters:
      dsc - descriptor of the data object
      Returns:
      data object
      Throws:
      Exception

    • newObject

      protected PsaRstApiObjBas newObject(Class<? extends PsaRstApiObjBas> object_class) throws Exception
      create a new JSON object
      Parameters:
      object_class - class of the JSON object
      Returns:
      object
      Throws:
      Exception

    • fetchRecord

      protected de.pisa.psc.srv.dto.PscDto fetchRecord() throws Exception
      fetch the record that is defined by the dataobject and GID in the event record
      Returns:
      dataobject with the record
      Throws:
      Exception
      javax.ws.rs.WebApplicationException - is the record was not found or more than one record was found

    • getFetchRecordKeyField

      protected String getFetchRecordKeyField(de.pisa.psc.srv.dto.PscDto dto)
      get the key field to search on in fetchRecord
      Parameters:
      dto - data object
      Returns:
      field descriptor

    • fetchRecord

      protected javax.ws.rs.core.Response fetchRecord(Class<? extends PsaRstApiObjBas> object_class) throws Exception
      fetch a record and return the JSON response
      Parameters:
      object_class - class of the JSON object
      Returns:
      response
      Throws:
      Exception

    • loadRecord

      protected javax.ws.rs.core.Response loadRecord(de.pisa.psc.srv.dto.PscDto dto, int row, Class<? extends PsaRstApiObjBas> object_class) throws Exception
      load a record into to a JSON response
      Parameters:
      dto - data object
      row - row to load
      object_class - class of the JSON object
      Returns:
      response
      Throws:
      Exception

    • buildResponse

      protected javax.ws.rs.core.Response buildResponse(String json)
      build the response
      Parameters:
      json - entity data
      Returns:
      a 200 OK status with an application/json entity

    • queryRecords

      protected de.pisa.psc.srv.dto.PscDto queryRecords(PsaRstApiQue query, Class<?> object_class) throws Exception
      set the query on a data object based on the request query
      Parameters:
      query - query
      object_class - class of JSON object
      Returns:
      data object with a query and an order
      Throws:
      Exception

    • queryRecordsSetQuery

      protected void queryRecordsSetQuery(PsaRstApiQue query, de.pisa.psc.srv.dto.PscDto dto, List<PsaRstApiMapFld.MapEntry> field_mapping) throws Exception
      Set the queries on a data object
      Parameters:
      query - query
      dto - data object
      field_mapping - field mapping
      Throws:
      Exception

    • mapQuery

      protected Optional<String> mapQuery(de.pisa.psc.srv.dto.PscDto dto, de.pisa.psc.srv.dto.PscFld field, String query) throws Exception
      map a query string to a string that can be used by the data object
      Parameters:
      dto - data object
      field - field
      query - query
      Returns:
      mapped query
      Throws:
      Exception

    • queryRecordsAddSort

      protected void queryRecordsAddSort(PsaRstApiQue query, de.pisa.psc.srv.dto.PscDto dto, List<PsaRstApiMapFld.MapEntry> field_mapping) throws de.pisa.psc.srv.glb.PscExc
      Add the sorting to a data object
      Parameters:
      query - query
      dto - data object
      field_mapping - field mapping
      Throws:
      de.pisa.psc.srv.glb.PscExc

    • queryRecord

      protected de.pisa.psc.srv.dto.PscDto queryRecord() throws Exception
      set the primary key query on a data object
      Returns:
      new data object with the query
      Throws:
      Exception

    • getQuery

      protected PsaRstApiQue getQuery() throws Exception
      get the query from the event data
      Returns:
      query
      Throws:
      Exception

    • getContinuation

      protected String getContinuation() throws Exception
      get the continuation key
      Returns:
      key
      Throws:
      Exception

    • fetchRecords

      protected javax.ws.rs.core.Response fetchRecords(Class<? extends PsaRstApiObjBas> object_class) throws Exception
      fetch records and return the JSON response
      Parameters:
      object_class - class of the JSON object
      Returns:
      response
      Throws:
      Exception

    • newPsaRstApiObjLis

      protected <T> PsaRstApiObjLis<T> newPsaRstApiObjLis()
      create a new result list object
      Type Parameters:
      T - type of the objects in the list
      Returns:
      list

    • fetchEurekaRecords

      protected javax.ws.rs.core.Response fetchEurekaRecords(PsaRstApiQue query, Class<? extends PsaRstApiObjBas> object_class) throws Exception
      fetch records with the use of EUREKA and return the JSON response
      Parameters:
      query - query
      object_class - class of the JSON object
      Returns:
      response
      Throws:
      Exception

    • queryEurekaRecords

      protected void queryEurekaRecords(PsaRstApiQue query, de.pisa.psc.srv.dto.PscDto dto, de.pisa.psa.dto.PsaRecClo rec_clo, List<PsaRstApiMapFld.MapEntry> field_mapping) throws Exception
      set queries for EUREKA
      Parameters:
      query - query
      dto - target data object
      rec_clo - record cloner
      field_mapping - field mapping
      Throws:
      Exception

    • getEurekaHighlighting

      protected PsaRstApiEvtHdl.EurekaHighlighting getEurekaHighlighting() throws Exception
      get the highlight configuration for the EUREKA search
      Returns:
      configuration
      Throws:
      Exception

    • fetchEureka

      protected javax.ws.rs.core.Response fetchEureka() throws Exception
      fetch ERUEKA result and return the JSON response
      Returns:
      response
      Throws:
      Exception

    • getEurekaDtoQuery

      protected EurekaDtoQuery getEurekaDtoQuery() throws Exception
      get the EUREKA query conditions for the configured data object
      Returns:
      query
      Throws:
      Exception

    • queryEureka

      protected EurekaResult queryEureka(String query, String[] dto_query, String key_001, String key_002, String key_003, PsaRstApiEvtHdl.EurekaHighlighting eureka_highlighting) throws Exception
      query the EUREKA index
      Parameters:
      query - query string
      dto_query - dataobject query
      key_001 - KEY_001 query
      key_002 - KEY_002 query
      key_003 - KEY_003 query
      eureka_highlighting - highlighting configuration for the occurrences in the preview
      Returns:
      search result
      Throws:
      Exception

    • getEurekaQueryField

      protected de.pisa.psa.dto.psa_idx.itf.DocFld getEurekaQueryField()
      get the field to query with EUREKA
      Returns:
      document field

    • getField

      protected de.pisa.psc.srv.dto.PscFld getField(de.pisa.psc.srv.dto.PscDto dto, String field_name, List<PsaRstApiMapFld.MapEntry> field_mapping)
      get the data object field for a JSON field name
      Parameters:
      dto - data object
      field_name - JSON field name
      field_mapping - field mapping
      Returns:
      field
      Throws:
      javax.ws.rs.ClientErrorException - if the field was not found