test of new table in database and check try

web/server/codechecker_server/api/authentication.py

@@ -11,7 +11,6 @@
 
 import datetime
 import sqlite3
-import os
 
 from authlib.integrations.requests_client import OAuth2Session
 from authlib.common.security import generate_token
@@ -29,8 +28,8 @@
 
 from codechecker_server.profiler import timeit
 
-from ..database.config_db_model import Product, ProductPermission, Session, \
-    SystemPermission
+from ..database.config_db_model import Product, ProductPermission, Session,\
+    StateCodes, SystemPermission
 from ..database.database import DBSession
 from ..permissions import handler_from_scope_params as make_handler, \
     require_manager, require_permission
@@ -52,8 +51,6 @@ def __init__(self, manager, auth_session, config_database):
         self.__manager = manager
         self.__auth_session = auth_session
         self.__config_db = config_database
-        self.__db_path = os.path.expanduser(
-            '~/.codechecker/state_codes.sqlite')
 
     def __require_privilaged_access(self):
         """
@@ -152,33 +149,6 @@ def getAccessControl(self):
             globalPermissions=global_permissions,
             productPermissions=product_permissions)
 
-    @timeit
-    def createdatabase(self):
-        """
-        Create the SQLite database for storing the state codes
-        """
-
-        # Check if the database file exists
-        if os.path.exists(self.__db_path):
-            LOG.debug(f"Database of states {self.__db_path} already exists.")
-            return
-
-        # Create the database and the table
-        # Create the database and the table
-        try:
-            conn = sqlite3.connect(self.__db_path)
-            conn.execute(
-                "CREATE TABLE state_codes ("
-                "ID INTEGER PRIMARY KEY AUTOINCREMENT, "
-                "state TEXT, "
-                "expires_at DATETIME)"
-            )
-            conn.close()
-            LOG.debug("successfully created"
-                      f" Database of states {self.__db_path}")
-        except sqlite3.Error as e:
-            LOG.error(f"An error occurred: {e}")
-
     @timeit
     def insertState(self, state):
         """
@@ -188,34 +158,41 @@ def insertState(self, state):
         # remove all the expired state codes from the database
         try:
             date = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-            conn = sqlite3.connect(self.__db_path)
-            conn.execute("DELETE FROM state_codes "
-                         "WHERE expires_at < DATETIME(\"" + date + "\")")
-            conn.commit()
-            conn.close()
+            with DBSession(self.__config_db) as session:
+
+                session.execute("DELETE FROM state_codes "
+                                "WHERE expires_at < DATETIME(\"" + date + "\")")
+                session.commit()
+            LOG.info("Expired state codes removed successfully.")
         except sqlite3.Error as e:
-            LOG.error(f"An error occurred: {e}")
+            LOG.error(f"An error occurred insertion: {e}")
 
         # Insert the state code into the database
         try:
-            date = (datetime.datetime.now() + datetime.timedelta(minutes=15)) \
-                .strftime("%Y-%m-%d %H:%M:%S")
-            conn = sqlite3.connect(self.__db_path)
-            # Insert the state code into the database
-            conn.execute("INSERT INTO state_codes (state, expires_at) "
-                         "VALUES (?, ?)", (state, date))
-            conn.commit()
-            state_id = conn.execute("SELECT ID FROM state_codes "
-                                    "WHERE state = ? AND expires_at = ?",
-                                    (state, date)).fetchone()[0]
-            conn.close()
-            LOG.debug(f"State {state[0]} inserted successfully.")
+            with DBSession(self.__config_db) as session:
+                LOG.debug(f"State {state} insertion started.")
+                date = (datetime.datetime.now() +
+                        datetime.timedelta(minutes=15))
+
+                new_state = StateCodes(state=state, expires_at=date)
+                session.add(new_state)
+                session.commit()
+                LOG.debug("State inserted into the database")
+
+                state_id = session.query(StateCodes) \
+                    .filter(StateCodes.state == new_state.state
+                            and StateCodes.expires_at == new_state.expires_at) \
+                    .first().id
+
+                LOG.debug("FETCHED STATE ID")
+                LOG.debug(f"State {state} inserted successfully with ID {state_id}")
+                LOG.debug(f"State {state[0]} inserted successfully.")
             return state_id
         except sqlite3.Error as e:
-            LOG.error(f"An error occurred: {e}")
+            LOG.error(f"An error occurred: {e}")  # added here re1move
             raise codechecker_api_shared.ttypes.RequestFailed(
                 codechecker_api_shared.ttypes.ErrorCode.AUTH_DENIED,
-                "STATE insertion failed.")
+                "STATE insertion failed. Please try again.")
 
     @timeit
     def getOauthProviders(self):
@@ -226,13 +203,6 @@ def createLink(self, provider):
         """
         For creating a autehntication link for OAuth for specified provider
         """
-        try:
-            self.createdatabase()
-        except Exception as ex:
-            LOG.error("Database creation failed: %s", str(ex))
-            raise codechecker_api_shared.ttypes.RequestFailed(
-                codechecker_api_shared.ttypes.ErrorCode.AUTH_DENIED,
-                "Database creation failed.")
         oauth_config = self.__manager.get_oauth_config(provider)
         if not oauth_config.get('enabled'):
             raise codechecker_api_shared.ttypes.RequestFailed(
@@ -266,14 +236,12 @@ def createLink(self, provider):
                 "State code insertion failed.")
 
         LOG.debug(f"State {state} inserted successfully with ID {state_id}")
-        print(url + "&state_id=" + str(state_id)) # added here re1move
         return url + "&state_id=" + str(state_id)
 
     @timeit
     def performLogin(self, auth_method, auth_string):
-        print("**********************")
-        print(auth_method, auth_string)
-        print("**********************")
+        print(f" ********** auth_method: {auth_method}")
+        print(f" ********** auth_string: {auth_string}")
 
         if not auth_string:
             raise codechecker_api_shared.ttypes.RequestFailed(
@@ -308,16 +276,13 @@ def performLogin(self, auth_method, auth_string):
             code = parsed_query.get("code")[0]
             state = parsed_query.get("state")[0]
             state_id = parsed_query.get("state_id")[0]
+            state_db = None
+            with DBSession(self.__config_db) as session:
 
-            conn = sqlite3.connect(self.__db_path)
-            state_db = conn.execute("SELECT state "
-                                    "FROM state_codes "
-                                    "WHERE ID = " + state_id).fetchone()[0]
-
-            # Delete the state from the database
-            conn.execute('DELETE FROM state_codes WHERE ID = ' + state_id)
-            conn.close()
-
+                state_db = session.query(StateCodes) \
+                    .filter(StateCodes.id == state_id) \
+                    .first().state
+            # Delete the state from the database # THINK ABOUT ME
             if state_db != state:
                 LOG.error("State code mismatch.")
                 raise codechecker_api_shared.ttypes.RequestFailed(

web/server/codechecker_server/database/config_db_model.py

@@ -158,6 +158,18 @@ def __init__(self, config_key, config_value):
         self.config_value = config_value
 
 
+class StateCodes(Base):
+    __tablename__ = 'state_codes'
+
+    id = Column(Integer, autoincrement=True, primary_key=True)
+    state = Column(String, nullable=False)
+    expires_at = Column(DateTime)
+
+    def __init__(self, state, expires_at):
+        self.state = state
+        self.expires_at = expires_at
+
+
 IDENTIFIER = {
     'identifier': "ConfigDatabase",
     'orm_meta': CC_META

web/server/codechecker_server/migrations/config/versions/5bdea278c415_create_a_state_table_for_verification_.py

@@ -0,0 +1,37 @@
+"""
+Create a state table for verification for OAuth
+
+Revision ID: 5bdea278c415
+Revises:     00099e8bc212
+Create Date: 2024-10-09 16:14:33.235797
+"""
+
+from logging import getLogger
+
+from alembic import op
+import sqlalchemy as sa
+
+# Revision identifiers, used by Alembic.
+revision = '5bdea278c415'
+down_revision = '00099e8bc212'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    LOG = getLogger("migration/config")
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.create_table('state_codes',
+    sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
+    sa.Column('state', sa.String(), nullable=False),
+    sa.Column('expires_at', sa.DateTime(), nullable=True),
+    sa.PrimaryKeyConstraint('id', name=op.f('pk_state_codes'))
+    )
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    LOG = getLogger("migration/config")
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_table('state_codes')
+    # ### end Alembic commands ###

web/tests/functional/authentication/oauth_server.py

@@ -87,8 +87,7 @@ def login_tester(self):
                 if query_result:
                     state = params['state']
                     code = query_result['code']
-                    state_id = params['state_id'] # added here re1move
-                    return self.show_json({"code": code, "state": state, "state_id": state_id}) # added here re1move
+                    return self.show_json({"code": code, "state": state})
             return self.show_rejection("Invalid credentials")
         except IndexError:
             return self.show_rejection("Invalid query parameters")

web/tests/functional/authentication/test_authentication.py

@@ -198,9 +198,9 @@ def try_login(self, provider, username, password):
             raise RequestFailed(data['error'])
 
         link = link.split('?')[0]
-        code, state, state_id = data['code'], data['state'], data['state_id'] # added here re1move
-        auth_string = f"{link}?code={code}&state={state}&state_id={state_id}" # added here re1move
-        #login?code=b297074a409d34818198&state=msuPS01qPAQrTsxYKMeVpDlG0hd3uc&state_id=4
+        code, state = data['code'], data['state']
+        auth_string = f"{link}?code={code}&state={state}"
+
         self.session_token = auth_client.performLogin(
             "oauth", provider + "@" + auth_string)