added new SDK api

Author: joroscoSF

src/datacustomcode/client.py

@@ -14,17 +14,18 @@
 # limitations under the License.
 from __future__ import annotations
 
+import io
+
 from enum import Enum
 from typing import (
     TYPE_CHECKING,
     ClassVar,
     Optional,
 )
-
 from pyspark.sql import SparkSession
-
 from datacustomcode.config import SparkConfig, config
 from datacustomcode.io.reader.base import BaseDataCloudReader
+from datacustomcode.file.reader.base import BaseFileReader
 
 if TYPE_CHECKING:
     from pyspark.sql import DataFrame as PySparkDataFrame
@@ -112,6 +113,7 @@ class Client:
     _instance: ClassVar[Optional[Client]] = None
     _reader: BaseDataCloudReader
     _writer: BaseDataCloudWriter
+    _file: BaseFileReader
     _data_layer_history: dict[DataCloudObjectType, set[str]]
 
     def __new__(
@@ -154,6 +156,7 @@ def __new__(
                 writer_init = writer
             cls._instance._reader = reader_init
             cls._instance._writer = writer_init
+            cls._instance._file = BaseFileReader()
             cls._instance._data_layer_history = {
                 DataCloudObjectType.DLO: set(),
                 DataCloudObjectType.DMO: set(),
@@ -212,6 +215,12 @@ def write_to_dmo(
         self._validate_data_layer_history_does_not_contain(DataCloudObjectType.DLO)
         return self._writer.write_to_dmo(name, dataframe, write_mode, **kwargs)
 
+    def file_open(self, file_name: str) -> io.TextIOWrapper:
+        """Read a file from the local file system.
+        """
+
+        return self._file.file_open(file_name)
+
     def _validate_data_layer_history_does_not_contain(
         self, data_cloud_object_type: DataCloudObjectType
     ) -> None:

src/datacustomcode/file/__init__.py

@@ -0,0 +1,21 @@
+# Copyright (c) 2025, Salesforce, Inc.
+# SPDX-License-Identifier: Apache-2
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+from __future__ import annotations
+
+from abc import ABC
+
+
+class BaseDataAccessLayer(ABC):
+    pass

src/datacustomcode/file/base.py

@@ -0,0 +1,51 @@
+# Copyright (c) 2025, Salesforce, Inc.
+# SPDX-License-Identifier: Apache-2
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+from __future__ import annotations
+
+import io
+import os
+
+from abc import abstractmethod
+from pathlib import Path
+from datacustomcode.file.base import BaseDataAccessLayer
+
+class BaseFileReader(BaseDataAccessLayer):
+    def file_open(self, file_name: str) -> io.TextIOWrapper:
+        default_code_pacakge = 'payload'
+        file_folder = 'files' # hardcoded folder name
+
+        file_path = None
+        if os.path.exists(default_code_pacakge):
+            relative = f"{default_code_pacakge}/{file_folder}/{file_name}"
+            file_path = Path.cwd().joinpath(relative)
+        else:
+            # find config.json, files folder is right next to the config.json
+            config_abs_path = Path(self.find_file_pathlib("config.json", Path.cwd()))
+            relative = f"{file_folder}/{file_name}"
+            file_path = config_abs_path.parent.joinpath(relative)
+        
+        file_handle = open(file_path, 'r')
+        #print(f"chuy file type: {type(foo), file_path}")
+        return file_handle
+
+    def find_file_pathlib(self, filename, search_path):
+        """
+        Finds a file within a directory and its subdirectories using pathlib.
+        Returns the full path of the first match found, or None if not found.
+        """
+        path_obj = Path(search_path)
+        for file_path in path_obj.rglob(filename):
+            return str(file_path)  # Convert Path object to string
+        return None