Skip to content

Commit

Permalink
Merge pull request #880 from isamu/fixType
Browse files Browse the repository at this point in the history
Fix type
  • Loading branch information
snakajima authored Jan 10, 2025
2 parents 473981f + 5af767e commit d7a1d3e
Show file tree
Hide file tree
Showing 18 changed files with 60 additions and 57 deletions.
18 changes: 9 additions & 9 deletions packages/graphai/src/graphai.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,18 +11,18 @@ import {
PropFunction,
GraphDataLoader,
ConfigDataDictionary,
} from "@/type";
import { TransactionLog } from "@/transaction_log";
} from "./type";
import { TransactionLog } from "./transaction_log";

import { ComputedNode, StaticNode, GraphNodes } from "@/node";
import { ComputedNode, StaticNode, GraphNodes } from "./node";

import { resultsOf, resultOf, cleanResult } from "@/utils/result";
import { propFunctions } from "@/utils/prop_function";
import { parseNodeName, assert, isLogicallyTrue } from "@/utils/utils";
import { getDataFromSource } from "@/utils/data_source";
import { resultsOf, resultOf, cleanResult } from "./utils/result";
import { propFunctions } from "./utils/prop_function";
import { parseNodeName, assert, isLogicallyTrue } from "./utils/utils";
import { getDataFromSource } from "./utils/data_source";

import { validateGraphData, validateAgent } from "@/validator";
import { TaskManager } from "@/task_manager";
import { validateGraphData, validateAgent } from "./validator";
import { TaskManager } from "./task_manager";

export const defaultConcurrency = 8;
export const graphDataLatestVersion = 0.5;
Expand Down
9 changes: 6 additions & 3 deletions packages/graphai/src/index.ts
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
export { GraphAI, defaultConcurrency, graphDataLatestVersion } from "./graphai";

export {
export type {
AgentFunction,
AgentFunctionInfo,
AgentFunctionInfoDictionary,
Expand All @@ -9,7 +9,6 @@ export {
GraphData,
ResultDataDictionary,
ResultData,
NodeState,
AgentFilterFunction,
AgentFilterInfo,
NodeData,
Expand All @@ -20,7 +19,11 @@ export {
DefaultParamsType,
GraphDataLoaderOption,
GraphDataLoader,
} from "@/type";
} from "./type";

export {
NodeState,
} from "./type";

export type { TransactionLog } from "./transaction_log";

Expand Down
14 changes: 7 additions & 7 deletions packages/graphai/src/node.ts
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
import type { GraphAI, GraphData } from "@/index";
import { strIntentionalError } from "@/utils/utils";
import { inputs2dataSources, dataSourceNodeIds } from "@/utils/nodeUtils";
import type { GraphAI, GraphData } from "./index";
import { strIntentionalError } from "./utils/utils";
import { inputs2dataSources, dataSourceNodeIds } from "./utils/nodeUtils";

import {
NodeDataParams,
Expand All @@ -18,10 +18,10 @@ import {
PassThrough,
ConsoleElement,
ConfigData,
} from "@/type";
import { parseNodeName, assert, isLogicallyTrue, isObject } from "@/utils/utils";
import { TransactionLog } from "@/transaction_log";
import { resultsOf } from "@/utils/result";
} from "./type";
import { parseNodeName, assert, isLogicallyTrue, isObject } from "./utils/utils";
import { TransactionLog } from "./transaction_log";
import { resultsOf } from "./utils/result";

export class Node {
public readonly nodeId: string;
Expand Down
4 changes: 2 additions & 2 deletions packages/graphai/src/task_manager.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { ComputedNode } from "@/node";
import { assert } from "@/utils/utils";
import { ComputedNode } from "./node";
import { assert } from "./utils/utils";

type TaskEntry = {
node: ComputedNode;
Expand Down
10 changes: 5 additions & 5 deletions packages/graphai/src/transaction_log.ts
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
import { ResultData, NodeDataParams, NodeState } from "@/type";
import type { GraphAI } from "@/graphai";
import type { ComputedNode, StaticNode } from "@/node";
import { debugResultKey } from "@/utils/utils";
import { dataSourceNodeIds } from "@/utils/nodeUtils";
import { ResultData, NodeDataParams, NodeState } from "./type";
import type { GraphAI } from "./graphai";
import type { ComputedNode, StaticNode } from "./node";
import { debugResultKey } from "./utils/utils";
import { dataSourceNodeIds } from "./utils/nodeUtils";

export class TransactionLog {
public nodeId: string;
Expand Down
4 changes: 2 additions & 2 deletions packages/graphai/src/type.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import type { TransactionLog } from "@/transaction_log";
import type { TaskManager } from "@/task_manager";
import type { TransactionLog } from "./transaction_log";
import type { TaskManager } from "./task_manager";

export enum NodeState {
Waiting = "waiting",
Expand Down
2 changes: 1 addition & 1 deletion packages/graphai/src/utils/data_source.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { ResultData, DataSource, PropFunction } from "@/type";
import { ResultData, DataSource, PropFunction } from "../type";
import { isObject, isNull } from "./utils";
import { propFunctionRegex } from "./prop_function";

Expand Down
2 changes: 1 addition & 1 deletion packages/graphai/src/utils/nodeUtils.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { parseNodeName, isObject } from "./utils";
import { DataSource } from "@/type";
import { DataSource } from "../type";

// for dataSource
export const inputs2dataSources = (inputs: any): DataSource[] => {
Expand Down
2 changes: 1 addition & 1 deletion packages/graphai/src/utils/prop_function.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { PropFunction } from "@/type";
import { PropFunction } from "../type";
import { isObject } from "./utils";

export const propFunctionRegex = /^[a-zA-Z]+\([^)]*\)$/;
Expand Down
8 changes: 4 additions & 4 deletions packages/graphai/src/utils/result.ts
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
import { DataSource, ResultData, PropFunction } from "@/type";
import { DataSource, ResultData, PropFunction } from "../type";

import { GraphNodes } from "@/node";
import { GraphNodes } from "../node";

import { parseNodeName, isNamedInputs, isObject, isNull } from "@/utils/utils";
import { getDataFromSource } from "@/utils/data_source";
import { parseNodeName, isNamedInputs, isObject, isNull } from "./utils";
import { getDataFromSource } from "./data_source";

const resultsOfInner = (input: any, nodes: GraphNodes, propFunctions: PropFunction[], isSelfNode: boolean = false): ResultData => {
if (Array.isArray(input)) {
Expand Down
2 changes: 1 addition & 1 deletion packages/graphai/src/utils/utils.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { DataSource, AgentFunction, DefaultInputData } from "@/type";
import { DataSource, AgentFunction, DefaultInputData } from "../type";

export const sleep = async (milliseconds: number) => {
return await new Promise((resolve) => setTimeout(resolve, milliseconds));
Expand Down
16 changes: 8 additions & 8 deletions packages/graphai/src/validator.ts
Original file line number Diff line number Diff line change
@@ -1,13 +1,13 @@
import { GraphData, AgentFunctionInfoDictionary } from "@/type";
import { GraphData, AgentFunctionInfoDictionary } from "./type";

import { graphNodesValidator, graphDataValidator } from "@/validators/graph_data_validator";
import { nodeValidator } from "@/validators/nodeValidator";
import { staticNodeValidator } from "@/validators/static_node_validator";
import { computedNodeValidator } from "@/validators/computed_node_validator";
import { relationValidator } from "@/validators/relation_validator";
import { agentValidator } from "@/validators/agent_validator";
import { graphNodesValidator, graphDataValidator } from "./validators/graph_data_validator";
import { nodeValidator } from "./validators/nodeValidator";
import { staticNodeValidator } from "./validators/static_node_validator";
import { computedNodeValidator } from "./validators/computed_node_validator";
import { relationValidator } from "./validators/relation_validator";
import { agentValidator } from "./validators/agent_validator";

import { ValidationError } from "@/validators/common";
import { ValidationError } from "./validators/common";

export const validateGraphData = (data: GraphData, agentIds: string[]) => {
graphNodesValidator(data);
Expand Down
2 changes: 1 addition & 1 deletion packages/graphai/src/validators/agent_validator.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { ValidationError } from "@/validators/common";
import { ValidationError } from "./common";

export const agentValidator = (graphAgentIds: Set<string>, agentIds: Set<string>) => {
graphAgentIds.forEach((agentId) => {
Expand Down
4 changes: 2 additions & 2 deletions packages/graphai/src/validators/computed_node_validator.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { ComputedNodeData } from "@/type";
import { computedNodeAttributeKeys, ValidationError } from "@/validators/common";
import { ComputedNodeData } from "../type";
import { computedNodeAttributeKeys, ValidationError } from "./common";

export const computedNodeValidator = (nodeData: ComputedNodeData) => {
Object.keys(nodeData).forEach((key) => {
Expand Down
4 changes: 2 additions & 2 deletions packages/graphai/src/validators/graph_data_validator.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { GraphData } from "@/type";
import { graphDataAttributeKeys, ValidationError } from "@/validators/common";
import { GraphData } from "../type";
import { graphDataAttributeKeys, ValidationError } from "./common";

export const graphNodesValidator = (data: GraphData) => {
if (data.nodes === undefined) {
Expand Down
4 changes: 2 additions & 2 deletions packages/graphai/src/validators/nodeValidator.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { NodeData, StaticNodeData, ComputedNodeData } from "@/type";
import { ValidationError } from "@/validators/common";
import { NodeData, StaticNodeData, ComputedNodeData } from "../type";
import { ValidationError } from "./common";

export const nodeValidator = (nodeData: NodeData) => {
if ((nodeData as ComputedNodeData).agent && (nodeData as StaticNodeData).value) {
Expand Down
8 changes: 4 additions & 4 deletions packages/graphai/src/validators/relation_validator.ts
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import { GraphData } from "@/type";
import { parseNodeName } from "@/utils/utils";
import { ValidationError } from "@/validators/common";
import { inputs2dataSources, dataSourceNodeIds } from "@/utils/nodeUtils";
import { GraphData } from "../type";
import { parseNodeName } from "../utils/utils";
import { inputs2dataSources, dataSourceNodeIds } from "../utils/nodeUtils";
import { ValidationError } from "./common";

export const relationValidator = (graphData: GraphData, staticNodeIds: string[], computedNodeIds: string[]) => {
const nodeIds = new Set<string>(Object.keys(graphData.nodes));
Expand Down
4 changes: 2 additions & 2 deletions packages/graphai/src/validators/static_node_validator.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { StaticNodeData } from "@/type";
import { staticNodeAttributeKeys, ValidationError } from "@/validators/common";
import { StaticNodeData } from "../type";
import { staticNodeAttributeKeys, ValidationError } from "./common";

export const staticNodeValidator = (nodeData: StaticNodeData) => {
Object.keys(nodeData).forEach((key) => {
Expand Down

0 comments on commit d7a1d3e

Please sign in to comment.