Skip to content

Csproj support #6

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
masum0813 merged 4 commits into from
Dec 4, 2025
Merged

Csproj support #6

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
217d8ae
Refactor repository handling: rename scanRepository to cloneRepositor…
Dec 4, 2025
358c73b
Enhance repository scanning and package management support:
Dec 4, 2025
0199236
Remove deprecated scanRepository function and clean up related code i…
Dec 4, 2025
c8f20db
Add support for parsing .csproj files and enhance repo URL validation
Dec 4, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 17 additions & 2 deletions apps/web/src/api/client.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -42,8 +42,8 @@ export function addVersion(libraryId, payload) {
});
}

export async function scanRepository(url) {
const res = await fetch(`${API_BASE}/libraries/repositories/scan`, {
export async function cloneRepository(url) {
const res = await fetch(`${API_BASE}/libraries/repositories/clone`, {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify({ url })
Expand All @@ -55,6 +55,21 @@ export async function scanRepository(url) {
return res.json();
}

export async function listRepositoryPackages({ root, url } = {}) {
const body = JSON.stringify(root ? { root } : { url });
const res = await fetch(`${API_BASE}/libraries/repositories/list-packages`, {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body,
});
if (!res.ok) {
const message = await res.text();
throw new Error(message || `Request failed with status ${res.status}`);
}
return res.json();
}


export async function analyzeFileUpload(file) {
const form = new FormData();
form.append('file', file);
Expand Down
3 changes: 3 additions & 0 deletions apps/web/src/components/ImportModal.jsx
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,9 @@
import { useState, useEffect, useRef } from 'react';
import { createLibrary, searchLibraries } from '../api/client.js';


//  TODO: RiskScore Gauge component'ı ortak bir yere taşı.

const RiskGauge = ({ score, level }) => {
if (score === undefined || score === null || Number.isNaN(score)) return null;
const clamped = Math.min(100, Math.max(0, Number(score)));
Expand Down
199 changes: 183 additions & 16 deletions apps/web/src/components/RepoModal.jsx
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import React, { useCallback, useEffect, useRef, useState } from 'react';
import { scanRepository, searchLibraries, createLibrary } from '../api/client.js';
import { cloneRepository, listRepositoryPackages, searchLibraries, createLibrary } from '../api/client.js';

const RiskBar = ({ score, explanation }) => {
if (score === undefined || score === null || Number.isNaN(score)) return null;
Expand All @@ -22,6 +22,7 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
const [error, setError] = useState(null);
const [loading, setLoading] = useState(false);
const [files, setFiles] = useState([]);
const [statusMessage, setStatusMessage] = useState('');
const [depJobs, setDepJobs] = useState([]);
const [processing, setProcessing] = useState(false);
const inputRef = useRef(null);
Expand All @@ -38,6 +39,9 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
return '(N/A)';
};

const totalJobs = depJobs.length;
const processedJobs = depJobs.filter(j => j.status !== 'pending').length;

const resetState = () => {
setRepoUrl('');
setError(null);
Expand Down Expand Up @@ -74,6 +78,13 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
return cleaned || null;
}, []);

const cancelledRef = React.useRef(false);
useEffect(() => {
return () => {
cancelledRef.current = true;
};
}, []);

const computeRisk = useCallback((match = {}) => {
const summaries = Array.isArray(match.licenseSummary ?? match.license_summary)
? (match.licenseSummary ?? match.license_summary)
Expand Down Expand Up @@ -123,9 +134,18 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
setError(null);
setFiles([]);
setDepJobs([]);
const res = await scanRepository(repoUrl);
const scannedFiles = res.files ?? [];

setStatusMessage('Cloning repository...');
const cloneRes = await cloneRepository(repoUrl);
setStatusMessage('Cloning repository completed.');
const root = cloneRes.root;

setStatusMessage('Listing dependency files...');
const listRes = await listRepositoryPackages({ root });
const scannedFiles = listRes.files ?? cloneRes.files ?? [];
setFiles(scannedFiles);

setStatusMessage('Scanning dependencies...');
const jobs = [];
scannedFiles.forEach((file, fIdx) => {
const deps = Array.isArray(file?.report?.dependencies) ? file.report.dependencies : [];
Expand All @@ -145,24 +165,154 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
});
});
setDepJobs(jobs);
// Process jobs sequentially: check local DB, fallback to MCP, persist if needed
setProcessing(true);
const updateJob = (id, patch) =>
setDepJobs(prev => prev.map(j => (j.id === id ? { ...j, ...patch } : j)));

for (const next of jobs) {
if (cancelledRef.current) break;
const q = next.version ? `${next.name} ${next.version}` : next.name;
try {
updateJob(next.id, { status: 'searching', message: null });
const res = await searchLibraries(q);
let match = null;
let existing = false;

if (res?.source === 'mongo' && Array.isArray(res?.results) && res.results.length > 0) {
existing = true;
const lib = res.results[0];
const v = lib.versions?.[0];
match = {
name: lib.name,
version: v?.version,
ecosystem: lib.ecosystem,
description: lib.description,
repository: lib.repository_url,
license: v?.license_name,
license_url: v?.license_url,
licenseSummary: v?.license_summary ?? [],
evidence: v?.evidence ?? [],
confidence: v?.confidence,
risk_level: v?.risk_level,
risk_score: v?.risk_score,
risk_score_explanation: v?.risk_score_explanation
};
} else if (res?.source === 'mcp' && Array.isArray(res?.results) && res.results.length > 0) {
const lib = res.results[0];
const v = lib.versions?.[0];
match = {
name: lib.name,
version: v?.version,
ecosystem: lib.ecosystem,
description: lib.description,
repository: lib.repository_url,
license: v?.license_name,
license_url: v?.license_url,
licenseSummary: v?.license_summary ?? [],
evidence: v?.evidence ?? [],
confidence: v?.confidence,
risk_level: v?.risk_level,
risk_score: v?.risk_score,
risk_score_explanation: v?.risk_score_explanation,
officialSite: lib.officialSite
};
} else if (res?.discovery?.matches?.length) {
match = res.discovery.bestMatch ?? res.discovery.matches[0];
}

if (!match) {
updateJob(next.id, { status: 'error', message: 'Eşleşme bulunamadı' });
continue;
}

const computedRisk = computeRisk(match);
const risk = {
level: match.risk_level ?? computedRisk.level,
score: match.risk_score ?? computedRisk.score,
explanation: match.risk_score_explanation ?? computedRisk.explanation
};

if (existing || res?.source === 'mongo') {
updateJob(next.id, {
status: 'done',
message: 'Zaten kayıtlı',
match,
risk_level: risk.level,
risk_score: risk.score,
risk_score_explanation: risk.explanation
});
continue;
}

updateJob(next.id, { status: 'importing', match, risk_level: risk.level, risk_score: risk.score, risk_score_explanation: risk.explanation });

const payload = {
name: match.name ?? next.name,
ecosystem: match.ecosystem ?? res?.discovery?.query?.ecosystem ?? 'unknown',
description: match.description,
repository_url: match.repository ?? match.officialSite ?? null,
officialSite: match.officialSite ?? match.repository ?? null,
versions: [
{
version: normalizeVersion(match.version ?? next.version) ?? 'unknown',
license_name: match.license ?? null,
license_url: match.license_url ?? null,
notes: match.summary ?? null,
license_summary: Array.isArray(match.licenseSummary)
? match.licenseSummary
.map(item =>
typeof item === 'object' && item !== null
? { summary: item.summary ?? '', emoji: item.emoji ?? null }
: { summary: item, emoji: null }
)
.filter(entry => typeof entry.summary === 'string' && entry.summary.length > 0)
: [],
confidence: match.confidence ?? null,
evidence: Array.isArray(match.evidence) ? match.evidence : [],
risk_level: risk.level,
risk_score: risk.score,
risk_score_explanation: risk.explanation
}
]
};

await createLibrary(payload);
updateJob(next.id, { status: 'done', message: 'Eklendi', match });
if (onImported) onImported();
} catch (err) {
updateJob(next.id, { status: 'error', message: err?.message ?? String(err) });
}
}

setProcessing(false);
} catch (err) {
setError(err.message);
setError(err?.message ?? String(err));
} finally {
setLoading(false);
}
};

useEffect(() => {
let cancelled = false;

const processNext = async () => {
if (cancelled) return;
if (processing) return;

const next = depJobs.find(job => job.status === 'pending');
if (!next) return;

setProcessing(true);
const updateJob = (id, patch) =>
setDepJobs(jobs => jobs.map(j => (j.id === id ? { ...j, ...patch } : j)));

const q = next.version ? `${next.name} ${next.version}` : next.name;

try {
updateJob(next.id, { status: 'searching', message: null });

// 1) Check local DB
const res = await searchLibraries(q);
let match = null;
let existing = false;
Expand All @@ -187,6 +337,7 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
risk_score_explanation: v?.risk_score_explanation
};
} else if (res?.source === 'mcp' && Array.isArray(res?.results) && res.results.length > 0) {
// MCP returned direct results
const lib = res.results[0];
const v = lib.versions?.[0];
match = {
Expand All @@ -206,6 +357,7 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
officialSite: lib.officialSite
};
} else if (res?.discovery?.matches?.length) {
// discovery bestMatch or matches
match = res.discovery.bestMatch ?? res.discovery.matches[0];
}

Expand Down Expand Up @@ -235,7 +387,9 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
return;
}

// persist MCP/discovery result into local DB
updateJob(next.id, { status: 'importing', match, risk_level: risk.level, risk_score: risk.score, risk_score_explanation: risk.explanation });

const payload = {
name: match.name ?? next.name,
ecosystem: match.ecosystem ?? res?.discovery?.query?.ecosystem ?? 'unknown',
Expand All @@ -250,12 +404,12 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
notes: match.summary ?? null,
license_summary: Array.isArray(match.licenseSummary)
? match.licenseSummary
.map(item =>
typeof item === 'object' && item !== null
? { summary: item.summary ?? '', emoji: item.emoji ?? null }
: { summary: item, emoji: null }
)
.filter(entry => typeof entry.summary === 'string' && entry.summary.length > 0)
.map(item =>
typeof item === 'object' && item !== null
? { summary: item.summary ?? '', emoji: item.emoji ?? null }
: { summary: item, emoji: null }
)
.filter(entry => typeof entry.summary === 'string' && entry.summary.length > 0)
: [],
confidence: match.confidence ?? null,
evidence: Array.isArray(match.evidence) ? match.evidence : [],
Expand All @@ -270,12 +424,19 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
updateJob(next.id, { status: 'done', message: 'Eklendi', match });
if (onImported) onImported();
} catch (err) {
updateJob(next.id, { status: 'error', message: err.message });
updateJob(next.id, { status: 'error', message: err?.message ?? String(err) });
} finally {
setStatusMessage('Scanning completed.');
setProcessing(false);
}
};

// try to drive processing whenever jobs change
processNext();

return () => {
cancelled = true;
};
}, [depJobs, processing, computeRisk, normalizeVersion, onImported]);

if (!isOpen) return null;
Expand All @@ -296,11 +457,11 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
✕
</button>
</div>
<div className="panel" style={{ background: 'transparent', boxShadow: 'none', color: 'white' }}>
<div className="panel" style={{ background: 'transparent', boxShadow: 'none', color: 'white', overflowY: 'visible' }}>
<p>Repo linkini girin, link geçerliyse tarayalım.</p>
<form
className="inline-form"
style={{ marginBottom: '1rem' }}
style={{ marginBottom: '0.5rem' }}
onSubmit={handleSubmit}
>
<input
Expand All @@ -311,15 +472,21 @@ export default function RepoLinkModal({ isOpen, onClose, onImported }) {
ref={inputRef}
/>
<div style={{ textAlign: 'right' }}>
<button type="submit" disabled={Boolean(error) || !repoUrl || loading} className="button">
{loading ? 'Taranıyor…' : 'Kontrol'}
<button type="submit" disabled={Boolean(error) || !repoUrl || loading || processing} className="button">
{(loading || processing) ? 'Taranıyor…' : 'Kontrol Et'}
</button>
</div>
</form>
{error && <p className="error">{error}</p>}
{statusMessage && (
<div style={{ marginBottom: '0.5rem', color: '#cbd5f5' }}>
{statusMessage}{(loading || processing) && totalJobs > 0 ? ` (${processedJobs}/${totalJobs})` : ''}
</div>
)}
{files.length > 0 && (
<div style={{ marginTop: '1rem', background: 'rgba(255,255,255,0.05)', padding: '0.75rem', borderRadius: '12px' }}>
<div style={{ marginTop: '1rem', background: 'rgba(255,255,255,0.05)', padding: '0.75rem', borderRadius: '12px', maxHeight: '320px', overflowY: 'auto', WebkitOverflowScrolling: 'touch' }}>
<p style={{ marginTop: 0, marginBottom: '0.5rem' }}>Bulunan dependency dosyaları:</p>

<ul style={{ margin: 0, paddingLeft: 0, color: 'white', listStyle: 'none', display: 'flex', flexDirection: 'column', gap: '0.6rem' }}>
{files.map((f, idx) => {
const deps = jobsByFile(f.path);
Expand Down
2 changes: 1 addition & 1 deletion apps/web/src/styles.css
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ body {
display: flex;
justify-content: space-between;
align-items: center;
margin-bottom: 1rem;
margin-bottom: 0.5rem;
}

.modal-header .close {
Expand Down
Loading
Loading